uk.co.strangeskies.observable

Class RetryingObserver<T>

java.lang.Object

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

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

All Implemented Interfaces:

Observer<T>

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

Constructor Summary

Constructors

Constructor and Description
RetryingObserver(Observer<? super T> downstreamObserver, Observable<? extends T> retryOn)

Method Summary

Modifier and Type	Method and Description
uk.co.strangeskies.observable.RetryingObserver.RetryingObservation	getObservation()
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.PassthroughObserver

getDownstreamObserver, initializeObservation, onComplete

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

RetryingObserver

public RetryingObserver(Observer<? super T> downstreamObserver,
                        Observable<? extends T> retryOn)

Method Detail

getObservation

public uk.co.strangeskies.observable.RetryingObserver.RetryingObservation getObservation()

Overrides:

getObservation in class PassthroughObserver<T,T>

onObserve

public void onObserve(Observation observation)

Specified by:

onObserve in interface Observer<T>

Overrides:

onObserve 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>

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