Home
last modified time | relevance | path

Searched refs:ResponseType (Results 1 – 25 of 31) sorted by relevance

12

/third_party/grpc/include/grpcpp/generic/
Dgeneric_stub.h43 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.py26 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.py30 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.py21 from ._typing import RequestType, ResponseType
134 class ServicerContext(Generic[RequestType, ResponseType], abc.ABC):
151 async def write(self, message: ResponseType) -> None: argument
D_interceptor.py30 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.py23 ResponseType = TypeVar('ResponseType') variable
/third_party/grpc/src/python/grpcio/grpc/experimental/aio/
D_base_call.py26 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.py30 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.py21 from ._typing import RequestType, ResponseType
134 class ServicerContext(Generic[RequestType, ResponseType], abc.ABC):
151 async def write(self, message: ResponseType) -> None: argument
D_interceptor.py30 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.py23 ResponseType = TypeVar('ResponseType') variable
/third_party/grpc/test/cpp/qps/
Dserver_async.cc47 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 …]
Dclient_async.cc63 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/
Dmethod_handler.h56 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 …]
Dserver_callback_handlers.h30 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 …]
Dserver_context.h67 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 …]
Dserver_context_impl.h69 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 …]
Dbyte_buffer.h39 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>
Dcompletion_queue.h63 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>
Dsync_stream_impl.h618 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 …]
Dsync_stream.h617 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 …]
Dcompletion_queue_impl.h66 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.py28 ResponseType = TypeVar('ResponseType') variable
183 ) -> ResponseType:
264 ) -> Iterator[ResponseType]:
344 ) -> ResponseType:
424 ) -> Iterator[ResponseType]:
/third_party/grpc/src/objective-c/ProtoRPC/
DProtoRPC.h80 @interface GRPCUnaryResponseHandler<ResponseType> : NSObject <GRPCProtoResponseHandler>
89 - (nullable instancetype)initWithResponseHandler:(void (^)(ResponseType, NSError *))handler
/third_party/grpc/src/csharp/Grpc.IntegrationTesting/
DMessages.cs829 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 …]

12