io.spine.grpc

Class DelegatingObserver<T>

java.lang.Object

io.spine.grpc.DelegatingObserver<T>

Type Parameters:

T - the observed type

All Implemented Interfaces:

io.grpc.stub.StreamObserver<T>

public abstract class DelegatingObserver<T>
extends java.lang.Object
implements io.grpc.stub.StreamObserver<T>

A stream observer which delegates calls to another observer of the same target type.

This class is meant to be used as an implementation base for observers which delegate all or some calls to a given observer. The implementations may discard calls to super when not required.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DelegatingObserver(io.grpc.stub.StreamObserver<? super T> delegate)

Method Summary

Modifier and Type	Method and Description
void	onCompleted()
void	onError(java.lang.Throwable t)
void	onNext(T value)

Methods inherited from class java.lang.Object

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

Constructor Detail

DelegatingObserver

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

Method Detail

onNext

public void onNext(T value)

Specified by:

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

onError

public void onError(java.lang.Throwable t)

Specified by:

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

onCompleted

public void onCompleted()

Specified by:

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