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>
AClientCall.Listener
that wraps aStreamObserver
and decrements outstandingRequestCount when a message is received.- Version:
- $Id: $Id
- Author:
- sduskis
-
-
Constructor Summary
Constructors Constructor and Description OutstandingRequestCountListener(io.grpc.stub.StreamObserver<ResponseT> observer, AtomicInteger outstandingRequestCount)
Constructor for OutstandingRequestCountListener.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method and Description void
onClose(io.grpc.Status status, io.grpc.Metadata trailers)
void
onMessage(ResponseT response)
-
-
-
Constructor Detail
-
OutstandingRequestCountListener
public OutstandingRequestCountListener(io.grpc.stub.StreamObserver<ResponseT> observer, AtomicInteger outstandingRequestCount)
Constructor for OutstandingRequestCountListener.- Parameters:
observer
- aStreamObserver
object.outstandingRequestCount
- aAtomicInteger
object.
-
-