Package io.grpc.stub

Class StreamObservers

java.lang.Object

io.grpc.stub.StreamObservers

public final class StreamObservers
extends Object

Utility functions for working with StreamObserver and it's common subclasses like CallStreamObserver.

Method Summary

Modifier and Type	Method	Description
static <V> void	copyWithFlowControl(Iterable<V> source, CallStreamObserver<V> target)	Deprecated. Of questionable utility and generally not used.
static <V> void	copyWithFlowControl(Iterator<V> source, CallStreamObserver<V> target)	Deprecated. Of questionable utility and generally not used.
static <T> void	nextAndComplete(StreamObserver<T> responseObserver, T response)	Utility method to call StreamObserver.onNext(Object) and StreamObserver.onCompleted() on the specified responseObserver.

Methods inherited from class java.lang.Object

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

Method Detail

nextAndComplete

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10957")
public static <T> void nextAndComplete(StreamObserver<T> responseObserver,
                                       T response)

Utility method to call StreamObserver.onNext(Object) and StreamObserver.onCompleted() on the specified responseObserver.

copyWithFlowControl

@Deprecated
@ExperimentalApi("https://github.com/grpc/grpc-java/issues/4694")
public static <V> void copyWithFlowControl(Iterator<V> source,
                                           CallStreamObserver<V> target)

Deprecated.

Of questionable utility and generally not used.

Copy the values of an Iterator to the target CallStreamObserver while properly accounting for outbound flow-control. After calling this method, target should no longer be used.

For clients this method is safe to call inside ClientResponseObserver.beforeStart(io.grpc.stub.ClientCallStreamObserver<ReqT>), on servers it is safe to call inside the service method implementation.

Parameters:

source - of values expressed as an Iterator.

target - CallStreamObserver which accepts values from the source.

copyWithFlowControl

@Deprecated
@ExperimentalApi("https://github.com/grpc/grpc-java/issues/4694")
public static <V> void copyWithFlowControl(Iterable<V> source,
                                           CallStreamObserver<V> target)

Deprecated.

Of questionable utility and generally not used.

Copy the values of an Iterable to the target CallStreamObserver while properly accounting for outbound flow-control. After calling this method, target should no longer be used.

For clients this method is safe to call inside ClientResponseObserver.beforeStart(io.grpc.stub.ClientCallStreamObserver<ReqT>), on servers it is safe to call inside the service method implementation.

Parameters:

source - of values expressed as an Iterable.

target - CallStreamObserver which accepts values from the source.