uk.co.strangeskies.observable

Class SafeObserver<T>

java.lang.Object

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

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

All Implemented Interfaces:

Observer<T>

Direct Known Subclasses:

ExecutorObserver

public class SafeObserver<T>
extends PassthroughObserver<T,T>

Constructor Summary

Constructors

Constructor and Description
SafeObserver(Observer<? super T> downstreamObserver)

Method Summary

Modifier and Type	Method and Description
protected boolean	assertCanMakeObservation(Observation observation)
protected boolean	assertIsMakingObservation()
protected void	cancelObservation()
uk.co.strangeskies.observable.SafeObserver.SafeObservation	getObservation()
protected void	initializeObservation(Observation observation)
protected boolean	isMakingObservation()
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)
void	tryAction(java.lang.Runnable action)
protected void	unmanagedError(java.lang.Throwable t)

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

SafeObserver

public SafeObserver(Observer<? super T> downstreamObserver)

Method Detail

onObserve

public void onObserve(Observation observation)

Specified by:

onObserve in interface Observer<T>

Overrides:

onObserve in class PassthroughObserver<T,T>

isMakingObservation

protected boolean isMakingObservation()

cancelObservation

protected void cancelObservation()

assertIsMakingObservation

protected boolean assertIsMakingObservation()

assertCanMakeObservation

protected boolean assertCanMakeObservation(Observation observation)

unmanagedError

protected void unmanagedError(java.lang.Throwable t)

initializeObservation

protected void initializeObservation(Observation observation)

Overrides:

initializeObservation in class PassthroughObserver<T,T>

getObservation

public uk.co.strangeskies.observable.SafeObserver.SafeObservation getObservation()

Overrides:

getObservation in class PassthroughObserver<T,T>

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>

Specified by:

onNext in class PassthroughObserver<T,T>

Parameters:

message - the message object instance

onComplete

public void onComplete()

Specified by:

onComplete in interface Observer<T>

Overrides:

onComplete in class PassthroughObserver<T,T>

onFail

public void onFail(java.lang.Throwable t)

Specified by:

onFail in interface Observer<T>

Overrides:

onFail in class PassthroughObserver<T,T>

tryAction

public void tryAction(java.lang.Runnable action)