StreamObserverAdapter (Cloud Bigtable HBase Client for Java 1.12.0 API)

com.google.cloud.bigtable.grpc.scanner

Class StreamObserverAdapter<T>

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

  • public class StreamObserverAdapter<T>
extends io.grpc.ClientCall.Listener<T>
    Adapts a StreamObserver to a ClientCall.Listener. ClientCall.request(int) will be called onNext.
    Version:
    $Id: $Id
    Author:
    sduskis

    • Constructor Detail

      • StreamObserverAdapter

        public StreamObserverAdapter(io.grpc.ClientCall<?,T> call,
                             io.grpc.stub.StreamObserver<T> observer)
        Constructor for StreamObserverAdapter.
        Parameters:
        call - a ClientCall object.
        observer - a StreamObserver object.

    • Method Detail

      • onMessage

        public void onMessage(T message)
        Overrides:
        onMessage in class io.grpc.ClientCall.Listener<T>

      • onClose

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