Class CollectingObserver<T,V,U,A,R>

java.lang.Object
io.helidon.grpc.server.CollectingObserver<T,V,U,A,R>
Type Parameters:
T - ToDo: Add JavaDoc
V - ToDo: Add JavaDoc
U - ToDo: Add JavaDoc
A - ToDo: Add JavaDoc
R - ToDo: Add JavaDoc
All Implemented Interfaces:
io.grpc.stub.StreamObserver<V>

public class CollectingObserver<T,V,U,A,R> extends Object implements io.grpc.stub.StreamObserver<V>
A StreamObserver.
  • Constructor Details

    • CollectingObserver

      public CollectingObserver(Collector<T,A,R> collector, io.grpc.stub.StreamObserver<U> responseObserver)
      ToDo: Add JavaDoc.
      Parameters:
      collector - ToDo: Add JavaDoc
      responseObserver - ToDo: Add JavaDoc
    • CollectingObserver

      public CollectingObserver(Collector<T,A,R> collector, io.grpc.stub.StreamObserver<U> responseObserver, Consumer<Throwable> errorHandler)
      ToDo: Add JavaDoc.
      Parameters:
      collector - ToDo: Add JavaDoc
      responseObserver - ToDo: Add JavaDoc
      errorHandler - ToDo: Add JavaDoc
    • CollectingObserver

      public CollectingObserver(Collector<T,A,R> collector, io.grpc.stub.StreamObserver<U> responseObserver, Function<V,T> requestConverter, Function<R,U> responseConverter)
      ToDo: Add JavaDoc.
      Parameters:
      collector - ToDo: Add JavaDoc
      responseObserver - ToDo: Add JavaDoc
      requestConverter - ToDo: Add JavaDoc
      responseConverter - ToDo: Add JavaDoc
    • CollectingObserver

      public CollectingObserver(Collector<T,A,R> collector, io.grpc.stub.StreamObserver<U> observer, Function<V,T> requestConverter, Function<R,U> responseConverter, Consumer<Throwable> errorHandler)
      ToDo: Add JavaDoc.
      Parameters:
      collector - ToDo: Add JavaDoc
      observer - ToDo: Add JavaDoc
      requestConverter - ToDo: Add JavaDoc
      responseConverter - ToDo: Add JavaDoc
      errorHandler - ToDo: Add JavaDoc
  • Method Details

    • onNext

      public void onNext(V value)
      Specified by:
      onNext in interface io.grpc.stub.StreamObserver<T>
    • onError

      public void onError(Throwable t)
      Specified by:
      onError in interface io.grpc.stub.StreamObserver<T>
    • onCompleted

      public void onCompleted()
      Specified by:
      onCompleted in interface io.grpc.stub.StreamObserver<T>