uk.co.strangeskies.observable

Class ColdObservable<M>

java.lang.Object

uk.co.strangeskies.observable.ColdObservable<M>

Type Parameters:

M - The type of event message to produce

All Implemented Interfaces:

Observable<M>

public class ColdObservable<M>
extends java.lang.Object
implements Observable<M>

A simple implementation of Observable which implements backpressure over the elements of an iterable.

The implementation is intentionally basic, with messages being pushed to the observer on the same thread which makes the request by default. An executor can be added downstream.

Constructor Summary

Constructors

Constructor and Description
ColdObservable(java.lang.Iterable<? extends M> iterable)

Method Summary

Modifier and Type	Method and Description
Disposable	observe(Observer<? super M> observer) Observers added will receive messages from this Observable.

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

aggregateBackpressure, aggregateBackpressure, collect, collectBackpressure, compose, concat, concat, concatMap, dropWhile, empty, executeOn, failingValue, filter, flatMap, get, getNext, map, materialize, merge, merge, mergeMap, observe, of, of, of, reduce, reduceBackpressure, reduceBackpressure, reduceBackpressure, repeating, requestNext, requestUnbounded, retrying, softReference, softReference, synchronize, synchronize, takeWhile, then, thenAfter, toObservable, toValue, toValue, toValue, tryGet, upcast, value, weakReference, weakReference

Constructor Detail

ColdObservable

public ColdObservable(java.lang.Iterable<? extends M> iterable)

Method Detail

observe

public Disposable observe(Observer<? super M> observer)

Description copied from interface: Observable

Observers added will receive messages from this Observable.

Specified by:

observe in interface Observable<M>

Parameters:

observer - an observer to add

Returns:

a disposable over the observation