uk.co.strangeskies.observable

Class MultiplePassthroughObserver<T>

java.lang.Object

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

Type Parameters:

T - The message type of the upstream observable and downstream observer

All Implemented Interfaces:

Observer<T>

public class MultiplePassthroughObserver<T>
extends java.lang.Object
implements Observer<T>

This is a helper class for implementing passive observables.

A passive observable is one which does not maintain a set of observations or manage its own events, instead deferring to one or more upstream observables. When an observer subscribes to a passive observable, typically the observer is decorated, and the decorator is then subscribed to the parents. This way the decorator can modify, inspect, or filter events as appropriate before passing them back through to the original observer.

This class is a partial implementation of such a decorator.

Constructor Summary

Constructors

Constructor and Description
MultiplePassthroughObserver(java.util.Collection<Observer<? super T>> downstreamObservers)
MultiplePassthroughObserver(Observer<? super T>... downstreamObservers)

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

MultiplePassthroughObserver

@SafeVarargs
public MultiplePassthroughObserver(Observer<? super T>... downstreamObservers)

MultiplePassthroughObserver

public MultiplePassthroughObserver(java.util.Collection<Observer<? super T>> downstreamObservers)

Method Detail

onObserve

public void onObserve(Observation observation)

Specified by:

onObserve in interface Observer<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>

Parameters:

message - the message object instance

onComplete

public void onComplete()

Specified by:

onComplete in interface Observer<T>

onFail

public void onFail(java.lang.Throwable t)

Specified by:

onFail in interface Observer<T>