/third_party/grpc/include/grpcpp/generic/ |
D | generic_stub.h | 43 template <class RequestType, class ResponseType> 53 std::unique_ptr<ClientAsyncReaderWriter<RequestType, ResponseType>> 63 std::unique_ptr<ClientAsyncResponseReader<ResponseType>> PrepareUnaryCall( in PrepareUnaryCall() 66 return std::unique_ptr<ClientAsyncResponseReader<ResponseType>>( in PrepareUnaryCall() 67 internal::ClientAsyncResponseReaderHelper::Create<ResponseType>( in PrepareUnaryCall() 80 std::unique_ptr<ClientAsyncReaderWriter<RequestType, ResponseType>> Call( in Call() 90 const RequestType* request, ResponseType* response, in UnaryCall() 101 const RequestType* request, ResponseType* response, in PrepareUnaryCall() 111 ClientBidiReactor<RequestType, ResponseType>* reactor) { in PrepareBidiStreamingCall() 126 const RequestType* request, ResponseType* response, in UnaryCall() [all …]
|
/third_party/grpc/src/python/grpcio/grpc/aio/ |
D | _base_call.py | 26 from ._typing import (DoneCallbackType, EOFType, RequestType, ResponseType) 134 class UnaryUnaryCall(Generic[RequestType, ResponseType], 140 def __await__(self) -> Awaitable[ResponseType]: 148 class UnaryStreamCall(Generic[RequestType, ResponseType], 153 def __aiter__(self) -> AsyncIterable[ResponseType]: 163 async def read(self) -> Union[EOFType, ResponseType]: 175 class StreamUnaryCall(Generic[RequestType, ResponseType], 196 def __await__(self) -> Awaitable[ResponseType]: 204 class StreamStreamCall(Generic[RequestType, ResponseType], 209 def __aiter__(self) -> AsyncIterable[ResponseType]: [all …]
|
D | _call.py | 30 RequestIterableType, RequestType, ResponseType, 263 def __await__(self) -> ResponseType: 292 _message_aiter: AsyncIterable[ResponseType] 314 async def _fetch_stream_responses(self) -> ResponseType: 323 def __aiter__(self) -> AsyncIterable[ResponseType]: 329 async def _read(self) -> ResponseType: 347 async def read(self) -> ResponseType: 489 async def _invoke(self) -> ResponseType: 539 async def _send_unary_request(self) -> ResponseType: 578 async def _conduct_rpc(self) -> ResponseType:
|
D | _base_server.py | 21 from ._typing import RequestType, ResponseType 134 class ServicerContext(Generic[RequestType, ResponseType], abc.ABC): 151 async def write(self, message: ResponseType) -> None: argument
|
D | _interceptor.py | 30 ResponseType, DoneCallbackType, RequestIterableType, 103 request: RequestType) -> Union[UnaryUnaryCall, ResponseType]: 437 _response_aiter: Optional[AsyncIterable[ResponseType]] 445 self) -> ResponseType: 450 def __aiter__(self) -> AsyncIterable[ResponseType]: 456 async def read(self) -> ResponseType: 859 _response: ResponseType 861 def __init__(self, response: ResponseType) -> None: argument 908 _response_iterator: AsyncIterable[ResponseType] 912 response_iterator: AsyncIterable[ResponseType]) -> None: argument [all …]
|
D | _typing.py | 23 ResponseType = TypeVar('ResponseType') variable
|
/third_party/grpc/src/python/grpcio/grpc/experimental/aio/ |
D | _base_call.py | 26 from ._typing import (DoneCallbackType, EOFType, RequestType, ResponseType) 134 class UnaryUnaryCall(Generic[RequestType, ResponseType], 140 def __await__(self) -> Awaitable[ResponseType]: 148 class UnaryStreamCall(Generic[RequestType, ResponseType], 153 def __aiter__(self) -> AsyncIterable[ResponseType]: 163 async def read(self) -> Union[EOFType, ResponseType]: 175 class StreamUnaryCall(Generic[RequestType, ResponseType], 196 def __await__(self) -> Awaitable[ResponseType]: 204 class StreamStreamCall(Generic[RequestType, ResponseType], 209 def __aiter__(self) -> AsyncIterable[ResponseType]: [all …]
|
D | _call.py | 30 RequestIterableType, RequestType, ResponseType, 263 def __await__(self) -> ResponseType: 292 _message_aiter: AsyncIterable[ResponseType] 314 async def _fetch_stream_responses(self) -> ResponseType: 323 def __aiter__(self) -> AsyncIterable[ResponseType]: 329 async def _read(self) -> ResponseType: 347 async def read(self) -> ResponseType: 490 async def _invoke(self) -> ResponseType: 540 async def _send_unary_request(self) -> ResponseType: 579 async def _conduct_rpc(self) -> ResponseType:
|
D | _base_server.py | 21 from ._typing import RequestType, ResponseType 134 class ServicerContext(Generic[RequestType, ResponseType], abc.ABC): 151 async def write(self, message: ResponseType) -> None: argument
|
D | _interceptor.py | 30 ResponseType, DoneCallbackType, RequestIterableType, 103 request: RequestType) -> Union[UnaryUnaryCall, ResponseType]: 438 _response_aiter: Optional[AsyncIterable[ResponseType]] 446 ) -> ResponseType: 451 def __aiter__(self) -> AsyncIterable[ResponseType]: 457 async def read(self) -> ResponseType: 860 _response: ResponseType 862 def __init__(self, response: ResponseType) -> None: argument 909 _response_iterator: AsyncIterable[ResponseType] 913 response_iterator: AsyncIterable[ResponseType]) -> None: argument [all …]
|
D | _typing.py | 23 ResponseType = TypeVar('ResponseType') variable
|
/third_party/grpc/test/cpp/qps/ |
D | server_async.cc | 47 template <class RequestType, class ResponseType, class ServiceType, 55 ServerAsyncResponseWriter<ResponseType>*, in AsyncQpsServerTest() argument 59 ServerAsyncReaderWriter<ResponseType, RequestType>*, in AsyncQpsServerTest() argument 63 ServerAsyncReader<ResponseType, RequestType>*, in AsyncQpsServerTest() argument 67 ServerAsyncWriter<ResponseType>*, CompletionQueue*, in AsyncQpsServerTest() argument 71 ServerAsyncReaderWriter<ResponseType, RequestType>*, in AsyncQpsServerTest() 75 ResponseType*)> in AsyncQpsServerTest() 253 grpc::ServerAsyncResponseWriter<ResponseType>*, in ServerRpcContextUnaryImpl() argument 256 std::function<grpc::Status(RequestType*, ResponseType*)> invoke_method) in ServerRpcContextUnaryImpl() 271 grpc::ServerAsyncResponseWriter<ResponseType>(srv_ctx_.get()); in Reset() [all …]
|
D | client_async.cc | 63 template <class RequestType, class ResponseType> 70 std::unique_ptr<grpc::ClientAsyncResponseReader<ResponseType>>( in ClientRpcContextUnaryImpl() 74 std::function<void(grpc::Status, ResponseType*, HistogramEntry*)> on_done) in ClientRpcContextUnaryImpl() argument 124 ResponseType response_; 127 std::function<void(grpc::Status, ResponseType*, HistogramEntry*)> callback_; 129 std::function<std::unique_ptr<grpc::ClientAsyncResponseReader<ResponseType>>( 135 std::unique_ptr<grpc::ClientAsyncResponseReader<ResponseType>> 335 template <class RequestType, class ResponseType> 342 grpc::ClientAsyncReaderWriter<RequestType, ResponseType>>( in ClientRpcContextStreamingPingPongImpl() 345 std::function<void(grpc::Status, ResponseType*)> on_done) in ClientRpcContextStreamingPingPongImpl() [all …]
|
/third_party/grpc/include/grpcpp/impl/codegen/ |
D | method_handler.h | 56 template <class ResponseType> 58 ResponseType* rsp, ::grpc::Status& status) { in UnaryRunHandlerHelper() 95 template <class ServiceType, class RequestType, class ResponseType, 97 class BaseResponseType = ResponseType> 102 const RequestType*, ResponseType*)> in RpcMethodHandler() 108 ResponseType rsp; in RunHandler() 133 const RequestType*, ResponseType*)> 140 template <class ServiceType, class RequestType, class ResponseType> 145 ServerReader<RequestType>*, ResponseType*)> in ClientStreamingHandler() 153 ResponseType rsp; in RunHandler() [all …]
|
D | server_callback_handlers.h | 30 template <class RequestType, class ResponseType> 35 const RequestType*, ResponseType*)> in CallbackUnaryHandler() 40 ::grpc::experimental::MessageAllocator<RequestType, ResponseType>* in SetMessageAllocator() 49 ::grpc::experimental::MessageHolder<RequestType, ResponseType>*>( in RunHandler() 85 ::grpc::experimental::MessageHolder<RequestType, ResponseType>* in Deserialize() 92 call, sizeof(DefaultMessageHolder<RequestType, ResponseType>))) in Deserialize() 93 DefaultMessageHolder<RequestType, ResponseType>(); in Deserialize() 110 const RequestType*, ResponseType*)> 112 ::grpc::experimental::MessageAllocator<RequestType, ResponseType>* 180 friend class CallbackUnaryHandler<RequestType, ResponseType>; [all …]
|
D | server_context.h | 67 template <class ServiceType, class RequestType, class ResponseType> 69 template <class RequestType, class ResponseType> 71 template <class RequestType, class ResponseType> 73 template <class RequestType, class ResponseType> 75 template <class RequestType, class ResponseType> 77 template <class ServiceType, class RequestType, class ResponseType> 79 template <class ResponseType> 81 ResponseType*, Status&); 82 template <class ServiceType, class RequestType, class ResponseType, 89 template <class ServiceType, class RequestType, class ResponseType> [all …]
|
D | server_context_impl.h | 69 template <class ServiceType, class RequestType, class ResponseType> 71 template <class RequestType, class ResponseType> 73 template <class RequestType, class ResponseType> 75 template <class RequestType, class ResponseType> 77 template <class RequestType, class ResponseType> 79 template <class ServiceType, class RequestType, class ResponseType> 81 template <class ServiceType, class RequestType, class ResponseType> 87 template <class ServiceType, class RequestType, class ResponseType> 356 template <class ServiceType, class RequestType, class ResponseType> 358 template <class ServiceType, class RequestType, class ResponseType> [all …]
|
D | byte_buffer.h | 39 template <class RequestType, class ResponseType> 41 template <class RequestType, class ResponseType> 46 template <class ServiceType, class RequestType, class ResponseType> 169 template <class ServiceType, class RequestType, class ResponseType> 171 template <class RequestType, class ResponseType> 173 template <class RequestType, class ResponseType>
|
D | completion_queue.h | 63 template <class ResponseType> 65 const ::grpc::internal::MethodHandler::HandlerParameter&, ResponseType*, 67 template <class ServiceType, class RequestType, class ResponseType, 70 template <class ServiceType, class RequestType, class ResponseType> 72 template <class ServiceType, class RequestType, class ResponseType> 274 template <class ResponseType> 276 const ::grpc::internal::MethodHandler::HandlerParameter&, ResponseType*, 278 template <class ServiceType, class RequestType, class ResponseType> 280 template <class ServiceType, class RequestType, class ResponseType>
|
D | sync_stream_impl.h | 618 template <class ServiceType, class RequestType, class ResponseType> 693 template <class ServiceType, class RequestType, class ResponseType> 822 template <class RequestType, class ResponseType> 824 : public ServerReaderWriterInterface<ResponseType, RequestType> { 862 using internal::WriterInterface<ResponseType>::Write; 863 bool Write(const ResponseType& response, in Write() 873 internal::ServerReaderWriterBody<ResponseType, RequestType> body_; 878 ServerUnaryStreamer<RequestType, ResponseType>, true>; 889 template <class RequestType, class ResponseType> 891 : public ServerReaderWriterInterface<ResponseType, RequestType> { [all …]
|
D | sync_stream.h | 617 template <class ServiceType, class RequestType, class ResponseType> 692 template <class ServiceType, class RequestType, class ResponseType> 819 template <class RequestType, class ResponseType> 821 : public ServerReaderWriterInterface<ResponseType, RequestType> { 859 using internal::WriterInterface<ResponseType>::Write; 860 bool Write(const ResponseType& response, in Write() 870 internal::ServerReaderWriterBody<ResponseType, RequestType> body_; 875 ServerUnaryStreamer<RequestType, ResponseType>, true>; 885 template <class RequestType, class ResponseType> 887 : public ServerReaderWriterInterface<ResponseType, RequestType> { [all …]
|
D | completion_queue_impl.h | 66 template <class ServiceType, class RequestType, class ResponseType> 68 template <class ServiceType, class RequestType, class ResponseType> 70 template <class ServiceType, class RequestType, class ResponseType> 275 template <class ServiceType, class RequestType, class ResponseType> 277 template <class ServiceType, class RequestType, class ResponseType> 279 template <class ServiceType, class RequestType, class ResponseType>
|
/third_party/grpc/src/python/grpcio/grpc/ |
D | _simple_stubs.py | 28 ResponseType = TypeVar('ResponseType') variable 183 ) -> ResponseType: 264 ) -> Iterator[ResponseType]: 344 ) -> ResponseType: 424 ) -> Iterator[ResponseType]:
|
/third_party/grpc/src/objective-c/ProtoRPC/ |
D | ProtoRPC.h | 80 @interface GRPCUnaryResponseHandler<ResponseType> : NSObject <GRPCProtoResponseHandler> 89 - (nullable instancetype)initWithResponseHandler:(void (^)(ResponseType, NSError *))handler
|
/third_party/grpc/src/csharp/Grpc.IntegrationTesting/ |
D | Messages.cs | 829 public global::Grpc.Testing.PayloadType ResponseType { property in Grpc.Testing.SimpleRequest 978 if (ResponseType != other.ResponseType) return false; in Equals() 994 …if (ResponseType != global::Grpc.Testing.PayloadType.Compressable) hash ^= ResponseType.GetHashCod… in GetHashCode() 1020 if (ResponseType != global::Grpc.Testing.PayloadType.Compressable) { in WriteTo() 1022 output.WriteEnum((int) ResponseType); in WriteTo() 1069 if (ResponseType != global::Grpc.Testing.PayloadType.Compressable) { in IBufferMessage.InternalWriteTo() 1071 output.WriteEnum((int) ResponseType); in IBufferMessage.InternalWriteTo() 1118 if (ResponseType != global::Grpc.Testing.PayloadType.Compressable) { in CalculateSize() 1119 size += 1 + pb::CodedOutputStream.ComputeEnumSize((int) ResponseType); in CalculateSize() 1159 if (other.ResponseType != global::Grpc.Testing.PayloadType.Compressable) { in MergeFrom() [all …]
|