CallController (Cloud Bigtable HBase Client for Java 1.12.0 API)

Class CallController<RequestT,ResponseT>

  • java.lang.Object
    • io.grpc.stub.CallStreamObserver<V>
      • io.grpc.stub.ClientCallStreamObserver<RequestT>
  • All Implemented Interfaces:

    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,
                           Throwable throwable)
        Specified by:
        cancel in class io.grpc.stub.ClientCallStreamObserver<RequestT>
      • isAutoFlowControlEnabled

        public boolean isAutoFlowControlEnabled()