Home
last modified time | relevance | path

Searched refs:Resp (Results 1 – 25 of 35) sorted by relevance

12

/external/rust/crates/grpcio/src/
Dclient.rs34 pub fn unary_call<Req, Resp>( in unary_call() argument
36 method: &Method<Req, Resp>, in unary_call()
39 ) -> Result<Resp> { in unary_call() argument
44 pub fn unary_call_async<Req, Resp>( in unary_call_async() argument
46 method: &Method<Req, Resp>, in unary_call_async()
49 ) -> Result<ClientUnaryReceiver<Resp>> { in unary_call_async() argument
56 pub fn client_streaming<Req, Resp>( in client_streaming() argument
58 method: &Method<Req, Resp>, in client_streaming()
60 ) -> Result<(ClientCStreamSender<Req>, ClientCStreamReceiver<Resp>)> { in client_streaming() argument
67 pub fn server_streaming<Req, Resp>( in server_streaming() argument
[all …]
Dserver.rs181 pub fn add_unary_handler<Req, Resp, F>( in add_unary_handler() argument
183 method: &Method<Req, Resp>, in add_unary_handler() argument
188 Resp: 'static, in add_unary_handler()
189 F: FnMut(RpcContext<'_>, Req, UnarySink<Resp>) + Send + Clone + 'static, in add_unary_handler()
201 pub fn add_client_streaming_handler<Req, Resp, F>( in add_client_streaming_handler() argument
203 method: &Method<Req, Resp>, in add_client_streaming_handler() argument
208 Resp: 'static, in add_client_streaming_handler()
209 F: FnMut(RpcContext<'_>, RequestStream<Req>, ClientStreamingSink<Resp>) in add_client_streaming_handler()
224 pub fn add_server_streaming_handler<Req, Resp, F>( in add_server_streaming_handler() argument
226 method: &Method<Req, Resp>, in add_server_streaming_handler() argument
[all …]
/external/rust/crates/grpcio/src/call/
Dclient.rs105 pub fn unary_async<Req, Resp>( in unary_async() argument
107 method: &Method<Req, Resp>, in unary_async()
110 ) -> Result<ClientUnaryReceiver<Resp>> { in unary_async() argument
130 pub fn client_streaming<Req, Resp>( in client_streaming() argument
132 method: &Method<Req, Resp>, in client_streaming()
134 ) -> Result<(ClientCStreamSender<Req>, ClientCStreamReceiver<Resp>)> { in client_streaming() argument
158 pub fn server_streaming<Req, Resp>( in server_streaming() argument
160 method: &Method<Req, Resp>, in server_streaming()
163 ) -> Result<ClientSStreamReceiver<Resp>> { in server_streaming() argument
189 pub fn duplex_streaming<Req, Resp>( in duplex_streaming() argument
[all …]
Dmod.rs115 pub struct Method<Req, Resp> {
126 pub resp_mar: Marshaller<Resp>,
129 impl<Req, Resp> Method<Req, Resp> {
144 pub fn resp_ser(&self) -> SerializeFn<Resp> { in resp_ser() argument
150 pub fn resp_de(&self) -> DeserializeFn<Resp> { in resp_de() argument
/external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/reflection/v1alpha/
DServerReflectionGrpc.java184 private static final class MethodHandlers<Req, Resp> implements
185 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
186 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
187 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
188 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
199 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
209 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
/external/grpc-grpc-java/alts/src/generated/main/grpc/io/grpc/alts/internal/
DHandshakerServiceGrpc.java192 private static final class MethodHandlers<Req, Resp> implements
193 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
194 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
195 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
196 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
207 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
217 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
/external/grpc-grpc-java/grpclb/src/generated/main/grpc/io/grpc/lb/v1/
DLoadBalancerGrpc.java182 private static final class MethodHandlers<Req, Resp> implements
183 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
184 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
185 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
186 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
197 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
207 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
/external/grpc-grpc-java/services/src/generated/test/grpc/io/grpc/reflection/testing/
DDynamicServiceGrpc.java218 private static final class MethodHandlers<Req, Resp> implements
219 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
220 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
221 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
222 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
233 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
247 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
DAnotherDynamicServiceGrpc.java218 private static final class MethodHandlers<Req, Resp> implements
219 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
220 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
221 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
222 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
233 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
247 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
DReflectableServiceGrpc.java191 private static final class MethodHandlers<Req, Resp> implements
192 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
193 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
194 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
195 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
206 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
220 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
/external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/
DUnimplementedServiceGrpc.java223 private static final class MethodHandlers<Req, Resp> implements
224 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
225 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
226 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
227 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
238 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
252 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
DReconnectServiceGrpc.java276 private static final class MethodHandlers<Req, Resp> implements
277 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
278 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
279 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
280 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
291 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
309 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
DMetricsServiceGrpc.java278 private static final class MethodHandlers<Req, Resp> implements
279 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
280 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
281 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
282 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
293 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
311 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
DTestServiceGrpc.java751 private static final class MethodHandlers<Req, Resp> implements
752 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
753 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
754 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
755 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
766 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
796 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
/external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/
DReportQpsScenarioServiceGrpc.java203 private static final class MethodHandlers<Req, Resp> implements
204 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
205 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
206 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
207 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
218 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
232 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
DWorkerServiceGrpc.java427 private static final class MethodHandlers<Req, Resp> implements
428 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
429 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
430 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
431 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
442 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
460 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
DBenchmarkServiceGrpc.java473 private static final class MethodHandlers<Req, Resp> implements
474 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
475 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
476 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
477 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
488 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
506 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
/external/tensorflow/tensorflow/core/distributed_runtime/
Dworker_interface.h206 template <typename Method, typename Req, typename Resp>
207 Status CallAndWait(Method func, const Req* req, Resp* resp) { in CallAndWait()
218 template <typename Method, typename Req, typename Resp>
219 Status CallAndWaitWithOptions(Method func, const Req* req, Resp* resp) { in CallAndWaitWithOptions()
/external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/health/v1/
DHealthGrpc.java315 private static final class MethodHandlers<Req, Resp> implements
316 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
317 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
318 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
319 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
330 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
348 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
/external/grpc-grpc-java/compiler/src/testLite/golden/
DTestDeprecatedService.java.txt226 private static final class MethodHandlers<Req, Resp> implements
227 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
228 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
229 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
230 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
241 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) {
255 io.grpc.stub.StreamObserver<Resp> responseObserver) {
/external/flatbuffers/tests/MyGame/Example/
DMonsterStorageGrpc.java403 private static final class MethodHandlers<Req, Resp> implements
404 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
405 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
406 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
407 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
418 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
436 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
/external/grpc-grpc-java/compiler/src/test/golden/
DTestDeprecatedService.java.txt227 private static final class MethodHandlers<Req, Resp> implements
228 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
229 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
230 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
231 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
242 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) {
256 io.grpc.stub.StreamObserver<Resp> responseObserver) {
/external/grpc-grpc-java/compiler/src/testNano/golden/
DTestDeprecatedService.java.txt252 private static final class MethodHandlers<Req, Resp> implements
253 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
254 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
255 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
256 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
267 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) {
281 io.grpc.stub.StreamObserver<Resp> responseObserver) {
/external/grpc-grpc-java/testing-proto/src/generated/main/grpc/io/grpc/testing/protobuf/
DSimpleServiceGrpc.java412 private static final class MethodHandlers<Req, Resp> implements
413 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
414 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
415 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
416 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
427 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
445 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
/external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/channelz/v1/
DChannelzGrpc.java637 private static final class MethodHandlers<Req, Resp> implements
638 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
639 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
640 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
641 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
652 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
686 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()

12