Home
last modified time | relevance | path

Searched refs:asyncBidiStreamingCall (Results 1 – 25 of 28) sorted by relevance

12

/external/grpc-grpc-java/alts/src/generated/main/grpc/io/grpc/alts/internal/
DHandshakerServiceGrpc.java4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
108 asyncBidiStreamingCall( in bindService()
147 return asyncBidiStreamingCall( in doHandshake()
/external/grpc-grpc-java/grpclb/src/generated/main/grpc/io/grpc/lb/v1/
DLoadBalancerGrpc.java4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
103 asyncBidiStreamingCall( in bindService()
137 return asyncBidiStreamingCall( in balanceLoad()
/external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/reflection/v1alpha/
DServerReflectionGrpc.java4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
104 asyncBidiStreamingCall( in bindService()
139 return asyncBidiStreamingCall( in serverReflectionInfo()
/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
DServerCallsTest.java92 ServerCalls.asyncBidiStreamingCall( in runtimeStreamObserverIsServerCallStreamObserver()
142 ServerCalls.asyncBidiStreamingCall( in cannotSetOnCancelHandlerAfterServiceInvocation()
170 ServerCalls.asyncBidiStreamingCall( in cannotSetOnReadyHandlerAfterServiceInvocation()
198 ServerCalls.asyncBidiStreamingCall( in cannotDisableAutoFlowControlAfterServiceInvocation()
220 ServerCalls.asyncBidiStreamingCall( in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages()
378 .addMethod(STREAMING_METHOD, ServerCalls.asyncBidiStreamingCall( in inprocessTransportManualFlow()
DClientCallsTest.java259 ClientCalls.asyncBidiStreamingCall(call, new ClientResponseObserver<Integer, String>() { in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages()
322 ClientCalls.asyncBidiStreamingCall(call, responseObserver); in callStreamObserverPropagatesFlowControlRequestsToCall()
376 .addMethod(STREAMING_METHOD, ServerCalls.asyncBidiStreamingCall( in inprocessTransportInboundFlowControl()
437 ClientCalls.asyncBidiStreamingCall(clientCall, responseObserver); in inprocessTransportInboundFlowControl()
457 .addMethod(STREAMING_METHOD, ServerCalls.asyncBidiStreamingCall( in inprocessTransportOutboundFlowControl()
528 ClientCalls.asyncBidiStreamingCall(clientCall, responseObserver); in inprocessTransportOutboundFlowControl()
/external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/
DWorkerServiceGrpc.java4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
239 asyncBidiStreamingCall( in bindService()
246 asyncBidiStreamingCall( in bindService()
299 return asyncBidiStreamingCall( in runServer()
315 return asyncBidiStreamingCall( in runClient()
DBenchmarkServiceGrpc.java4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
284 asyncBidiStreamingCall( in bindService()
305 asyncBidiStreamingCall( in bindService()
353 return asyncBidiStreamingCall( in streamingCall()
389 return asyncBidiStreamingCall( in streamingBothWays()
DReportQpsScenarioServiceGrpc.java4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
/external/flatbuffers/tests/MyGame/Example/
DMonsterStorageGrpc.java11 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
18 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
277 asyncBidiStreamingCall( in bindService()
332 return asyncBidiStreamingCall( in getMinMaxHitPoints()
/external/grpc-grpc-java/compiler/src/testLite/golden/
DTestService.java.txt4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
343 asyncBidiStreamingCall(
350 asyncBidiStreamingCall(
357 asyncBidiStreamingCall(
432 return asyncBidiStreamingCall(
446 return asyncBidiStreamingCall(
458 return asyncBidiStreamingCall(
DTestDeprecatedService.java.txt4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
/external/grpc-grpc-java/compiler/src/test/golden/
DTestService.java.txt4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
349 asyncBidiStreamingCall(
356 asyncBidiStreamingCall(
363 asyncBidiStreamingCall(
438 return asyncBidiStreamingCall(
452 return asyncBidiStreamingCall(
464 return asyncBidiStreamingCall(
DTestDeprecatedService.java.txt4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
/external/grpc-grpc-java/testing-proto/src/generated/main/grpc/io/grpc/testing/protobuf/
DSimpleServiceGrpc.java4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
256 asyncBidiStreamingCall( in bindService()
326 return asyncBidiStreamingCall( in bidiStreamingRpc()
/external/grpc-grpc-java/compiler/src/testNano/golden/
DTestService.java.txt4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
384 asyncBidiStreamingCall(
391 asyncBidiStreamingCall(
398 asyncBidiStreamingCall(
473 return asyncBidiStreamingCall(
487 return asyncBidiStreamingCall(
499 return asyncBidiStreamingCall(
DTestDeprecatedService.java.txt4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
/external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/
DTestServiceGrpc.java4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
450 asyncBidiStreamingCall( in bindService()
457 asyncBidiStreamingCall( in bindService()
563 return asyncBidiStreamingCall( in fullDuplexCall()
577 return asyncBidiStreamingCall( in halfDuplexCall()
DUnimplementedServiceGrpc.java4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
DReconnectServiceGrpc.java4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
DMetricsServiceGrpc.java4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
/external/grpc-grpc-java/services/src/generated/test/grpc/io/grpc/reflection/testing/
DAnotherDynamicServiceGrpc.java4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
DReflectableServiceGrpc.java4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
DDynamicServiceGrpc.java4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
/external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/
DAbstractBenchmark.java437 StreamObserver<ByteBuf> requestObserver = ClientCalls.asyncBidiStreamingCall( in startStreamingCalls()
491 StreamObserver<ByteBuf> requestObserver = ClientCalls.asyncBidiStreamingCall( in startFlowControlledStreamingCalls()
/external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/health/v1/
DHealthGrpc.java4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;

12