Searched refs:ClientResponseObserver (Results 1 – 5 of 5) sorted by relevance
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/manualflowcontrol/ |
| D | ManualFlowControlClient.java | 22 import io.grpc.stub.ClientResponseObserver;
47 ClientResponseObserver<HelloRequest, HelloReply> clientResponseObserver = in main()
48 new ClientResponseObserver<HelloRequest, HelloReply>() { in main()
|
| /external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/ |
| D | ClientCallsTest.java | 259 ClientCalls.asyncBidiStreamingCall(call, new ClientResponseObserver<Integer, String>() { in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages()
287 ClientResponseObserver<Integer, String> responseObserver = in callStreamObserverPropagatesFlowControlRequestsToCall()
288 new ClientResponseObserver<Integer, String>() { in callStreamObserverPropagatesFlowControlRequestsToCall()
332 ClientResponseObserver<Integer, String> responseObserver = in canCaptureInboundFlowControlForServerStreamingObserver()
333 new ClientResponseObserver<Integer, String>() { in canCaptureInboundFlowControlForServerStreamingObserver()
412 ClientResponseObserver<Integer, Integer> responseObserver = in inprocessTransportInboundFlowControl()
413 new ClientResponseObserver<Integer, Integer>() { in inprocessTransportInboundFlowControl()
492 ClientResponseObserver<Integer, Integer> responseObserver = in inprocessTransportOutboundFlowControl()
493 new ClientResponseObserver<Integer, Integer>() { in inprocessTransportOutboundFlowControl()
|
| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | ClientResponseObserver.java | 26 public interface ClientResponseObserver<ReqT, RespT> extends StreamObserver<RespT> { interface
|
| D | ClientCalls.java | 400 if (observer instanceof ClientResponseObserver) { in StreamObserverToCallListenerAdapter()
402 ClientResponseObserver<ReqT, RespT> clientResponseObserver = in StreamObserverToCallListenerAdapter()
403 (ClientResponseObserver<ReqT, RespT>) observer; in StreamObserverToCallListenerAdapter()
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/ |
| D | ProtoReflectionServiceTest.java | 48 import io.grpc.stub.ClientResponseObserver;
590 implements ClientResponseObserver<ServerReflectionRequest, ServerReflectionResponse> {
|