Home
last modified time | relevance | path

Searched refs:RequestT (Results 1 – 17 of 17) sorted by relevance

/external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/
Dmessage_allocator.h41 template <typename RequestT, typename ResponseT>
48 RequestT* request() { return request_; } in request()
52 void set_request(RequestT* request) { request_ = request; } in set_request()
57 RequestT* request_;
65 template <typename RequestT, typename ResponseT>
69 virtual MessageHolder<RequestT, ResponseT>* AllocateMessages() = 0;
82 template <typename RequestT, typename ResponseT>
83 using MessageHolder = ::grpc::MessageHolder<RequestT, ResponseT>;
85 template <typename RequestT, typename ResponseT>
86 using MessageAllocator = ::grpc::MessageAllocator<RequestT, ResponseT>;
/external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/
Dmessage_allocator.h41 template <typename RequestT, typename ResponseT>
48 RequestT* request() { return request_; } in request()
52 void set_request(RequestT* request) { request_ = request; } in set_request()
57 RequestT* request_;
65 template <typename RequestT, typename ResponseT>
69 virtual MessageHolder<RequestT, ResponseT>* AllocateMessages() = 0;
82 template <typename RequestT, typename ResponseT>
83 using MessageHolder = ::grpc::MessageHolder<RequestT, ResponseT>;
85 template <typename RequestT, typename ResponseT>
86 using MessageAllocator = ::grpc::MessageAllocator<RequestT, ResponseT>;
/external/dagger2/java/dagger/grpc/server/
DProxyServerCallHandler.java37 public final class ProxyServerCallHandler<RequestT, ResponseT>
52 private final MethodDescriptor<RequestT, ResponseT> delegateMethodDescriptor;
60 public static <RequestT, ResponseT> ServerMethodDefinition<InputStream, InputStream> proxyMethod( in proxyMethod()
61 MethodDescriptor<RequestT, ResponseT> delegateMethodDescriptor, in proxyMethod() argument
73 MethodDescriptor<RequestT, ResponseT> delegateMethodDescriptor, in ProxyServerCallHandler() argument
83 ServerMethodDefinition<RequestT, ResponseT> delegateMethod = getMethodDefinition(headers); in startCall()
84 Listener<RequestT> delegateListener = in startCall()
92 private ServerMethodDefinition<RequestT, ResponseT> getMethodDefinition(Metadata headers) { in getMethodDefinition()
97 return (ServerMethodDefinition<RequestT, ResponseT>) methodDefinition; in getMethodDefinition()
119 private final Listener<RequestT> delegate;
[all …]
/external/openscreen/osp/public/
Drequest_response_handler.h56 template <typename RequestT,
57 typename RequestCoderTraits = DefaultRequestCoderTraits<RequestT>>
64 virtual void OnMatchedResponse(RequestT* request,
65 typename RequestT::ResponseMsgType* response,
67 virtual void OnError(RequestT* request, Error error) = 0;
93 RequestT>::value,
116 RequestT>::value,
166 if (message_type != RequestT::kResponseType) { in OnStreamMessage()
169 typename RequestT::ResponseMsgType response; in OnStreamMessage()
197 RequestT request;
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DServerCallHandler.java26 public interface ServerCallHandler<RequestT, ResponseT> {
41 ServerCall.Listener<RequestT> startCall( in startCall()
42 ServerCall<RequestT, ResponseT> call, in startCall() argument
DChannel.java46 public abstract <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall( in newCall()
47 MethodDescriptor<RequestT, ResponseT> methodDescriptor, CallOptions callOptions); in newCall() argument
DMethodDescriptor.java210 public static <RequestT, ResponseT> MethodDescriptor<RequestT, ResponseT> create( in create()
212 Marshaller<RequestT> requestMarshaller, in create()
214 return new MethodDescriptor<RequestT, ResponseT>( in create()
/external/dagger2/javatests/dagger/grpc/functional/server/
DCountingInterceptor.java44 public <RequestT, ResponseT> Listener<RequestT> interceptCall( in interceptCall()
45 ServerCall<RequestT, ResponseT> call, in interceptCall() argument
47 ServerCallHandler<RequestT, ResponseT> next) { in interceptCall() argument
/external/llvm-project/clang-tools-extra/clangd/index/remote/
DClient.cpp29 template <typename RequestT, typename ReplyT>
32 const RequestT &);
34 template <typename RequestT, typename ReplyT, typename ClangdRequestT,
37 StreamingCall<RequestT, ReplyT> RPCCall, in streamRPC() argument
40 trace::Span Tracer(RequestT::descriptor()->name()); in streamRPC()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DForwardingManagedChannel.java61 public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall( in newCall()
62 MethodDescriptor<RequestT, ResponseT> methodDescriptor, CallOptions callOptions) { in newCall() argument
DOobChannel.java193 public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall( in newCall()
194 MethodDescriptor<RequestT, ResponseT> methodDescriptor, CallOptions callOptions) { in newCall() argument
195 return new ClientCallImpl<RequestT, ResponseT>(methodDescriptor, in newCall()
/external/grpc-grpc-java/services/src/test/java/io/grpc/services/
DBinaryLogProviderTest.java104 public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall( in wrapChannel_methodDescriptor()
105 MethodDescriptor<RequestT, ResponseT> method, CallOptions callOptions) { in wrapChannel_methodDescriptor()
107 return new NoopClientCall<RequestT, ResponseT>(); in wrapChannel_methodDescriptor()
127 public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall( in wrapChannel_handler()
128 MethodDescriptor<RequestT, ResponseT> methodDescriptor, CallOptions callOptions) { in wrapChannel_handler()
129 return new NoopClientCall<RequestT, ResponseT>() { in wrapChannel_handler()
136 public void sendMessage(RequestT message) { in wrapChannel_handler()
DBinlogHelperTest.java993 public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall( in clientDeadlineLogged_deadlineSetViaCallOption()
994 MethodDescriptor<RequestT, ResponseT> methodDescriptor, in clientDeadlineLogged_deadlineSetViaCallOption()
996 return new NoopClientCall<RequestT, ResponseT>(); in clientDeadlineLogged_deadlineSetViaCallOption()
1046 public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall( in clientDeadlineLogged_deadlineSetViaContext()
1047 MethodDescriptor<RequestT, ResponseT> methodDescriptor, in clientDeadlineLogged_deadlineSetViaContext()
1049 return new NoopClientCall<RequestT, ResponseT>(); in clientDeadlineLogged_deadlineSetViaContext()
1089 public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall( in clientInterceptor()
1090 MethodDescriptor<RequestT, ResponseT> methodDescriptor, CallOptions callOptions) { in clientInterceptor()
1091 return new NoopClientCall<RequestT, ResponseT>() { in clientInterceptor()
1099 public void sendMessage(RequestT message) { in clientInterceptor()
[all …]
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DManagedChannelOrphanWrapperTest.java132 public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall( in newCall()
133 MethodDescriptor<RequestT, ResponseT> methodDescriptor, CallOptions callOptions) { in newCall() argument
DManagedChannelImplTest.java610 public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> interceptCall( in interceptor()
611 MethodDescriptor<RequestT, ResponseT> method, CallOptions callOptions, in interceptor()
/external/grpc-grpc-java/android/src/main/java/io/grpc/android/
DAndroidChannelBuilder.java286 public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall( in newCall()
287 MethodDescriptor<RequestT, ResponseT> methodDescriptor, CallOptions callOptions) { in newCall() argument
/external/grpc-grpc-java/android/src/test/java/io/grpc/android/
DAndroidChannelBuilderTest.java394 public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall( in newCall()
395 MethodDescriptor<RequestT, ResponseT> methodDescriptor, CallOptions callOptions) { in newCall() argument