Core classes used by both the gRPC server and gRPC client.
-
CollectingObserver.create(Collector<T,A,R> collector,
io.grpc.stub.StreamObserver<U> observer)
Creates collecting observer from a collector and another observer.
Creates collecting observer from a collector, another observer and an error handler.
CollectingObserver.create(Collector<T,A,R> collector,
io.grpc.stub.StreamObserver<U> observer,
Function<V,T> requestConverter,
Function<R,U> responseConverter)
Creates collecting observer from a collector, another observer and converters.