Module io.helidon.grpc.core

Package io.helidon.grpc.core

Class SafeStreamObserver<T>

java.lang.Object

io.helidon.grpc.core.SafeStreamObserver<T>

Type Parameters:

T - the type of response expected

All Implemented Interfaces:

io.grpc.stub.StreamObserver<T>

public class SafeStreamObserver<T>
extends Object
implements io.grpc.stub.StreamObserver<T>

A StreamObserver that handles exceptions correctly.

Method Summary

Modifier and Type	Method	Description
io.grpc.stub.StreamObserver<? super T>	delegate()	Obtain the wrapped StreamObserver.
static <T> io.grpc.stub.StreamObserver<T>	ensureSafeObserver(io.grpc.stub.StreamObserver<T> observer)	Ensure that the specified StreamObserver is a safe observer.
void	onCompleted()
void	onError(Throwable thrown)
void	onNext(T t)

Methods inherited from class java.lang.Object

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

Method Details

onNext

public void onNext(T t)

Specified by:

onNext in interface io.grpc.stub.StreamObserver<T>

onError

public void onError(Throwable thrown)

Specified by:

onError in interface io.grpc.stub.StreamObserver<T>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface io.grpc.stub.StreamObserver<T>

delegate

public io.grpc.stub.StreamObserver<? super T> delegate()

Obtain the wrapped StreamObserver.

Returns:

the wrapped StreamObserver

ensureSafeObserver

public static <T> io.grpc.stub.StreamObserver<T> ensureSafeObserver(io.grpc.stub.StreamObserver<T> observer)

Ensure that the specified StreamObserver is a safe observer.

If the specified observer is not an instance of SafeStreamObserver then wrap it in a SafeStreamObserver.

Type Parameters:

T - the response type expected by the observer

Parameters:

observer - the StreamObserver to test

Returns:

a safe StreamObserver