uk.co.strangeskies.observable

Class ExecutorObserver<T>

java.lang.Object

uk.co.strangeskies.observable.PassthroughObserver<T,T>

uk.co.strangeskies.observable.SafeObserver<T>

uk.co.strangeskies.observable.ExecutorObserver<T>

All Implemented Interfaces:

Observer<T>

public class ExecutorObserver<T>
extends SafeObserver<T>

Constructor Summary

Constructors

Constructor and Description
ExecutorObserver(Observer<? super T> downstreamObserver, java.util.concurrent.Executor executor)

Method Summary

Modifier and Type	Method and Description
void	onComplete()
void	onFail(java.lang.Throwable t)
void	onNext(T message) The method which will receive notification from an Observable.
void	onObserve(Observation observation)

Methods inherited from class uk.co.strangeskies.observable.SafeObserver

assertCanMakeObservation, assertIsMakingObservation, cancelObservation, getObservation, initializeObservation, isMakingObservation, tryAction, unmanagedError

Methods inherited from class uk.co.strangeskies.observable.PassthroughObserver

getDownstreamObserver

Methods inherited from class java.lang.Object

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

Methods inherited from interface uk.co.strangeskies.observable.Observer

onCompletion, onFailure, onObservation, singleUse

Constructor Detail

ExecutorObserver

public ExecutorObserver(Observer<? super T> downstreamObserver,
                        java.util.concurrent.Executor executor)

Method Detail

onNext

public void onNext(T message)

Description copied from interface: Observer

The method which will receive notification from an Observable.

Specified by:

onNext in interface Observer<T>

Overrides:

onNext in class SafeObserver<T>

Parameters:

message - the message object instance

onObserve

public void onObserve(Observation observation)

Specified by:

onObserve in interface Observer<T>

Overrides:

onObserve in class SafeObserver<T>

onComplete

public void onComplete()

Specified by:

onComplete in interface Observer<T>

Overrides:

onComplete in class SafeObserver<T>

onFail

public void onFail(java.lang.Throwable t)

Specified by:

onFail in interface Observer<T>

Overrides:

onFail in class SafeObserver<T>