Home
last modified time | relevance | path

Searched refs:ClientCallStreamObserver (Results 1 – 7 of 7) sorted by relevance

/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/manualflowcontrol/
DManualFlowControlClient.java21 import io.grpc.stub.ClientCallStreamObserver;
50 ClientCallStreamObserver<HelloRequest> requestStream; in main()
53 public void beforeStart(final ClientCallStreamObserver<HelloRequest> requestStream) { in main()
/external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/
DProtoReflectionServiceTest.java47 import io.grpc.stub.ClientCallStreamObserver;
531 ClientCallStreamObserver<ServerReflectionRequest> requestObserver = in flowControl()
532 (ClientCallStreamObserver<ServerReflectionRequest>) in flowControl()
556 ClientCallStreamObserver<ServerReflectionRequest> requestObserver = in flowControlOnCompleteWithPendingRequest()
557 (ClientCallStreamObserver<ServerReflectionRequest>) in flowControlOnCompleteWithPendingRequest()
596 public void beforeStart(final ClientCallStreamObserver<ServerReflectionRequest> requestStream) { in beforeStart()
/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
DClientCallsTest.java261 public void beforeStart(ClientCallStreamObserver<Integer> requestStream) { in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages()
290 public void beforeStart(ClientCallStreamObserver<Integer> requestStream) { in callStreamObserverPropagatesFlowControlRequestsToCall()
335 public void beforeStart(ClientCallStreamObserver<Integer> requestStream) { in canCaptureInboundFlowControlForServerStreamingObserver()
415 public void beforeStart(final ClientCallStreamObserver<Integer> requestStream) { in inprocessTransportInboundFlowControl()
495 public void beforeStart(final ClientCallStreamObserver<Integer> requestStream) { in inprocessTransportOutboundFlowControl()
/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
DClientResponseObserver.java44 void beforeStart(final ClientCallStreamObserver<ReqT> requestStream); in beforeStart()
DClientCallStreamObserver.java34 public abstract class ClientCallStreamObserver<V> extends CallStreamObserver<V> { class
DClientCalls.java318 private static final class CallToStreamObserverAdapter<T> extends ClientCallStreamObserver<T> {
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DAbstractInteropTest.java81 import io.grpc.stub.ClientCallStreamObserver;
618 ClientCallStreamObserver<StreamingInputCallRequest> clientCallStreamObserver = in clientCompressedStreaming()
619 (ClientCallStreamObserver) in clientCompressedStreaming()