client/io.spine.grpc/MemoizingObserver

MemoizingObserver

public class MemoizingObserver<T>

The StreamObserver which stores the input data and then exposes it via API calls.

Parameters

<T>

the type of streamed objects

Constructors

MemoizingObserver

public void MemoizingObserver()

Creates new empty instance.

Functions

public T firstResponse()

Returns the first item which has been fed to this StreamObserver.

public Throwable getError()

Obtains the error if it has been received by this observer.

public boolean isCompleted()

Allows to understand whether the response has been completed.

public void onCompleted()

public void onError(Throwable t)

public void onNext(T value)

public List<T> responses()

Returns all the responses received so far.