CallController (Cloud Bigtable HBase Client for Java 1.12.0 API)

com.google.cloud.bigtable.grpc.async

Class CallController<RequestT,ResponseT>

  • java.lang.Object
    • io.grpc.stub.CallStreamObserver<V>
      • io.grpc.stub.ClientCallStreamObserver<RequestT>
        • com.google.cloud.bigtable.grpc.async.CallController<RequestT,ResponseT>
  • All Implemented Interfaces:
    io.grpc.stub.StreamObserver<RequestT>


    public class CallController<RequestT,ResponseT>
    extends io.grpc.stub.ClientCallStreamObserver<RequestT>
    Wraps a ClientCall, and implements ClientCallStreamObserver to allow access to the call's underlying functionality.

    This class is intended to be used by the user to control flow and the life of the call.

    • Constructor Detail

      • CallController

        public CallController()
    • Method Detail

      • onNext

        public void onNext(RequestT value)
      • onError

        public void onError(Throwable t)
      • onCompleted

        public void onCompleted()
      • isReady

        public boolean isReady()
        Specified by:
        isReady in class io.grpc.stub.CallStreamObserver<RequestT>
      • setOnReadyHandler

        public void setOnReadyHandler(Runnable onReadyHandler)
        Specified by:
        setOnReadyHandler in class io.grpc.stub.CallStreamObserver<RequestT>
      • request

        public void request(int count)
        Specified by:
        request in class io.grpc.stub.CallStreamObserver<RequestT>
      • setMessageCompression

        public void setMessageCompression(boolean enable)
        Specified by:
        setMessageCompression in class io.grpc.stub.CallStreamObserver<RequestT>
      • cancel

        public void cancel(@Nullable
                           String s,
                           @Nullable
                           Throwable throwable)
        Specified by:
        cancel in class io.grpc.stub.ClientCallStreamObserver<RequestT>
      • isAutoFlowControlEnabled

        public boolean isAutoFlowControlEnabled()