public class StreamObserverWrapper<T>
extends java.lang.Object
implements io.grpc.stub.StreamObserver<T>
Implements the StreamObserver interface containing three methods for receiving messages asynchronously:
Modifier and Type | Field and Description |
---|---|
protected StatusExceptionWrapper |
exceptionWrapper |
protected static java.util.logging.Logger |
log |
protected java.lang.String |
messageType |
protected boolean |
performValidation |
protected io.grpc.stub.StreamObserver |
wrappedObserver |
protected WrapperFactory |
wrapperFactory |
Constructor and Description |
---|
StreamObserverWrapper(io.grpc.stub.StreamObserver<?> wrappedObserver,
boolean performValidation,
java.lang.String messageType) |
Modifier and Type | Method and Description |
---|---|
void |
onCompleted()
Receives a notification of successful stream completion.
|
void |
onError(java.lang.Throwable t)
Receives a terminating error from the stream.
|
void |
onNext(java.lang.Object value)
Receives a value from the stream.
|
protected static java.util.logging.Logger log
protected io.grpc.stub.StreamObserver wrappedObserver
protected boolean performValidation
protected java.lang.String messageType
protected WrapperFactory wrapperFactory
protected StatusExceptionWrapper exceptionWrapper
public StreamObserverWrapper(io.grpc.stub.StreamObserver<?> wrappedObserver, boolean performValidation, java.lang.String messageType)
public void onNext(java.lang.Object value)
Can be called many times but is never called after onError(Throwable)
or onCompleted()
are called.
Unary calls must invoke onNext at most once. Clients may invoke onNext at most once for server streaming calls, but may receive many onNext callbacks. Servers may invoke onNext at most once for client streaming calls, but may receive many onNext callbacks.
If an exception is thrown by an implementation the caller is expected to terminate the
stream by calling onError(Throwable)
with the caught exception prior to
propagating it.
onNext
in interface io.grpc.stub.StreamObserver<T>
value
- the value passed to the streampublic void onError(java.lang.Throwable t)
May only be called once and if called it must be the last method called. In particular if an
exception is thrown by an implementation of onError
no further calls to any method are
allowed.
t
should be a StatusException
or StatusRuntimeException
, but other Throwable
types are possible. Callers should
generally convert from a Status
via Status.asException()
or
Status.asRuntimeException()
. Implementations should generally convert to a
Status
via Status.fromThrowable(Throwable)
.
onError
in interface io.grpc.stub.StreamObserver<T>
t
- the error occurred on the streampublic void onCompleted()
May only be called once and if called it must be the last method called. In particular if an
exception is thrown by an implementation of onCompleted
no further calls to any method
are allowed.
onCompleted
in interface io.grpc.stub.StreamObserver<T>