Searched refs:ClientCallStreamObserver (Results 1 – 7 of 7) sorted by relevance
21 import io.grpc.stub.ClientCallStreamObserver;50 ClientCallStreamObserver<HelloRequest> requestStream; in main()53 public void beforeStart(final ClientCallStreamObserver<HelloRequest> requestStream) { in main()
47 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()
261 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()
44 void beforeStart(final ClientCallStreamObserver<ReqT> requestStream); in beforeStart()
34 public abstract class ClientCallStreamObserver<V> extends CallStreamObserver<V> { class
318 private static final class CallToStreamObserverAdapter<T> extends ClientCallStreamObserver<T> {
81 import io.grpc.stub.ClientCallStreamObserver;618 ClientCallStreamObserver<StreamingInputCallRequest> clientCallStreamObserver = in clientCompressedStreaming()619 (ClientCallStreamObserver) in clientCompressedStreaming()