uk.co.strangeskies.observable

Interface Observer<T>

Type Parameters:

T - the type of message to observe

All Known Implementing Classes:

BackpressureReducingObserver, DropWhileObserver, ExecutorObserver, FilteringObserver, FlatMappingObserver, MappingObserver, MaterializingObserver, MultiplePassthroughObserver, PassthroughObserver, ReferenceObserver, ReferenceOwnedObserver, RepeatingObserver, RetryingObserver, SafeObserver, SynchronizedObserver, TakeWhileObserver

public interface Observer<T>

An observer over one or more Observable instances.

Method Summary

Modifier and Type	Method and Description
default void	onComplete()
static <T> Observer<T>	onCompletion(java.lang.Runnable action)
default void	onFail(java.lang.Throwable t)
static <T> Observer<T>	onFailure(java.util.function.Consumer<java.lang.Throwable> action)
void	onNext(T message) The method which will receive notification from an Observable.
static <T> Observer<T>	onObservation(java.util.function.Consumer<Observation> action)
default void	onObserve(Observation observation)
static <T> Observer<T>	singleUse(java.util.function.Function<Observation,Observer<T>> observerProvider)

Method Detail

onNext

void onNext(T message)

The method which will receive notification from an Observable.

Parameters:

message - the message object instance

onObserve

default void onObserve(Observation observation)

onComplete

default void onComplete()

onFail

default void onFail(java.lang.Throwable t)

onObservation

static <T> Observer<T> onObservation(java.util.function.Consumer<Observation> action)

onCompletion

static <T> Observer<T> onCompletion(java.lang.Runnable action)

onFailure

static <T> Observer<T> onFailure(java.util.function.Consumer<java.lang.Throwable> action)

singleUse

static <T> Observer<T> singleUse(java.util.function.Function<Observation,Observer<T>> observerProvider)