hu.akarnokd.reactive4java.util

Class ObservableToIterableAdapter<T,U>

java.lang.Object

hu.akarnokd.reactive4java.util.ObservableToIterableAdapter<T,U>

Type Parameters:

T - the observed element type

U - the iterated element type

All Implemented Interfaces:

CloseableIterable<U>, java.lang.Iterable<U>

Direct Known Subclasses:

Latest, MostRecent, Next, ToIterable

public abstract class ObservableToIterableAdapter<T,U>
extends java.lang.Object
implements CloseableIterable<U>

Base class to help receive values from an observable sequence through customizable iterator and observer.

Since:

0.97

Field Summary

Fields

Modifier and Type	Field and Description
protected Observable<? extends T>	observable The observable instance.

Constructor Summary

Constructors

Constructor and Description
ObservableToIterableAdapter(Observable<? extends T> observable) Constructor, saves the source observable.

Method Summary

Modifier and Type	Method and Description
CloseableIterator<U>	iterator()
protected abstract ObserverToIteratorSink<T,U>	run(java.io.Closeable handle) The factory method to return an iterator and hand over the close handle to the original registration to the source.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

observable

protected final Observable<? extends T> observable

The observable instance.

Constructor Detail

ObservableToIterableAdapter

public ObservableToIterableAdapter(@Nonnull
                                   Observable<? extends T> observable)

Constructor, saves the source observable.

Parameters:

observable - the source observable

Method Detail

iterator

public CloseableIterator<U> iterator()

Specified by:

iterator in interface CloseableIterable<U>

Specified by:

iterator in interface java.lang.Iterable<U>

run

@Nonnull
protected abstract ObserverToIteratorSink<T,U> run(@Nonnull
                                                             java.io.Closeable handle)

The factory method to return an iterator and hand over the close handle to the original registration to the source.

Parameters:

handle - the closea handle

Returns:

the closeable iterator