OutstandingRequestCountListener (Cloud Bigtable HBase Client for Java 1.12.0 API)

com.google.cloud.bigtable.grpc.scanner

Class OutstandingRequestCountListener<ResponseT>

  • java.lang.Object
    • io.grpc.ClientCall.Listener<ResponseT>
      • com.google.cloud.bigtable.grpc.scanner.OutstandingRequestCountListener<ResponseT>


  • public class OutstandingRequestCountListener<ResponseT>
    extends io.grpc.ClientCall.Listener<ResponseT>
    A ClientCall.Listener that wraps a StreamObserver and decrements outstandingRequestCount when a message is received.
    Version:
    $Id: $Id
    Author:
    sduskis
    • Constructor Detail

      • OutstandingRequestCountListener

        public OutstandingRequestCountListener(io.grpc.stub.StreamObserver<ResponseT> observer,
                                               AtomicInteger outstandingRequestCount)
        Constructor for OutstandingRequestCountListener.
        Parameters:
        observer - a StreamObserver object.
        outstandingRequestCount - a AtomicInteger object.
    • Method Detail

      • onMessage

        public void onMessage(ResponseT response)
        Overrides:
        onMessage in class io.grpc.ClientCall.Listener<ResponseT>
      • onClose

        public void onClose(io.grpc.Status status,
                            io.grpc.Metadata trailers)
        Overrides:
        onClose in class io.grpc.ClientCall.Listener<ResponseT>