Module io.helidon.webserver.grpc
Package io.helidon.webserver.grpc

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

java.lang.Object
io.helidon.webserver.grpc.CollectingObserver<T,V,U,A,R>
Type Parameters:
T - the type of input elements to the reduction operation
V - the request type before conversion
U - the type of values observed
A - the mutable accumulation type of the reduction operation
R - the result type of the reduction operation
All Implemented Interfaces:
io.grpc.stub.StreamObserver<V>
@Deprecated(forRemoval=true, since="4.1.0") public class CollectingObserver<T,V,U,A,R> extends Object implements io.grpc.stub.StreamObserver<V>
Deprecated, for removal: This API element is subject to removal in a future version.
use io.helidon.grpc.core.CollectingObserver instead.
Utility StreamObserver mostly used for testing.

  • Method Summary

    Modifier and Type
    Method
    Description
    static <T, V, U, A, R>
    CollectingObserver<T,V,U,A,R>
    create(Collector<T,A,R> collector, io.grpc.stub.StreamObserver<U> observer)
    Deprecated, for removal: This API element is subject to removal in a future version.
    Creates collecting observer from a collector and another observer.
    static <T, V, U, A, R>
    CollectingObserver<T,V,U,A,R>
    create(Collector<T,A,R> collector, io.grpc.stub.StreamObserver<U> observer, Consumer<Throwable> errorHandler)
    Deprecated, for removal: This API element is subject to removal in a future version.
    Creates collecting observer from a collector, another observer and an error handler.
    static <T, V, U, A, R>
    CollectingObserver<T,V,U,A,R>
    create(Collector<T,A,R> collector, io.grpc.stub.StreamObserver<U> observer, Function<V,T> requestConverter, Function<R,U> responseConverter)
    Deprecated, for removal: This API element is subject to removal in a future version.
    Creates collecting observer from a collector, another observer and converters.
    void
    onCompleted()
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    void
    onError(Throwable t)
    Deprecated, for removal: This API element is subject to removal in a future version.
     
    void
    onNext(V value)
    Deprecated, for removal: This API element is subject to removal in a future version.
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • create

      public static <T, V, U, A, R> CollectingObserver<T,V,U,A,R> create(Collector<T,A,R> collector, io.grpc.stub.StreamObserver<U> observer)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Creates collecting observer from a collector and another observer.
      Type Parameters:
      T - the type of input elements to the reduction operation
      V - the request type before conversion
      U - the type of values observed
      A - the mutable accumulation type of the reduction operation
      R - the result type of the reduction operation
      Parameters:
      collector - the collector
      observer - the observer
      Returns:
      new collecting observer

    • create

      public static <T, V, U, A, R> CollectingObserver<T,V,U,A,R> create(Collector<T,A,R> collector, io.grpc.stub.StreamObserver<U> observer, Consumer<Throwable> errorHandler)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Creates collecting observer from a collector, another observer and an error handler.
      Type Parameters:
      T - the type of input elements to the reduction operation
      V - the request type before conversion
      U - the type of values observed
      A - the mutable accumulation type of the reduction operation
      R - the result type of the reduction operation
      Parameters:
      collector - the collector
      observer - the observer
      errorHandler - the error handler
      Returns:
      new collecting observer

    • create

      public static <T, V, U, A, R> CollectingObserver<T,V,U,A,R> create(Collector<T,A,R> collector, io.grpc.stub.StreamObserver<U> observer, Function<V,T> requestConverter, Function<R,U> responseConverter)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Creates collecting observer from a collector, another observer and converters.
      Type Parameters:
      T - the type of input elements to the reduction operation
      V - the request type before conversion
      U - the type of values observed
      A - the mutable accumulation type of the reduction operation
      R - the result type of the reduction operation
      Parameters:
      collector - the collector
      observer - the observer
      requestConverter - request converter
      responseConverter - response converter
      Returns:
      new collecting observer

    • onNext

      public void onNext(V value)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Specified by:
      onNext in interface io.grpc.stub.StreamObserver<T>

    • onError

      public void onError(Throwable t)
      Deprecated, for removal: This API element is subject to removal in a future version.
      Specified by:
      onError in interface io.grpc.stub.StreamObserver<T>

    • onCompleted

      public void onCompleted()
      Deprecated, for removal: This API element is subject to removal in a future version.
      Specified by:
      onCompleted in interface io.grpc.stub.StreamObserver<T>