io.spine.grpc

Class CompositeObserver<T>

java.lang.Object

io.spine.grpc.CompositeObserver<T>

Type Parameters:

T - the observed type

All Implemented Interfaces:

io.grpc.stub.StreamObserver<T>

public final class CompositeObserver<T>
extends java.lang.Object
implements io.grpc.stub.StreamObserver<T>

A stream observer which delegates calls to multiple other observers with the same target type.

The observers are called in the exact same order in which they are specified on the object construction.

Constructor Summary

Constructors

Constructor and Description
CompositeObserver(java.lang.Iterable<io.grpc.stub.StreamObserver<? super T>> observers)

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

CompositeObserver

public CompositeObserver(java.lang.Iterable<io.grpc.stub.StreamObserver<? super T>> observers)

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>