web/io.spine.web.future/FutureObserver

FutureObserver

public final class FutureObserver<T>

A stream observer which can provide a CompletableFuture view on the stream.

This implementation works only with the unary gRPC calls, i.e. onNext cannot be called more then once.

Functions

public static FutureObserver<T> create<T>()

Creates a new instance of FutureObserver.

public void onCompleted()

public void onError(Throwable t)

public void onNext(T value)

public CompletableFuture<T> toFuture()

Retrieves the future view on this observer result.

public static FutureObserver<T> withDefault<T>(T defaultValue)

Creates a new instance of FutureObserver with the given defaultValue.