hu.akarnokd.reactive4java.reactive

Class ToIterable<T>

java.lang.Object

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

hu.akarnokd.reactive4java.reactive.ToIterable<T>

Type Parameters:

T - the element type to iterate

All Implemented Interfaces:

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

public final class ToIterable<T>
extends ObservableToIterableAdapter<T,T>

Convert the given observable instance into a classical iterable instance.

The resulting iterable does not support the remove() method.

Since:

0.97

Field Summary

Fields inherited from class hu.akarnokd.reactive4java.util.ObservableToIterableAdapter

observable

Constructor Summary

Constructors

Constructor and Description
ToIterable(Observable<? extends T> observable) Constructor.

Method Summary

Modifier and Type	Method and Description
protected ObserverToIteratorSink<T,T>	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 hu.akarnokd.reactive4java.util.ObservableToIterableAdapter

iterator

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

Constructor Detail

ToIterable

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

Constructor.

Parameters:

observable - the observable to convert

Method Detail

run

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

Description copied from class: ObservableToIterableAdapter

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

Specified by:

run in class ObservableToIterableAdapter<T,T>

Parameters:

handle - the closea handle

Returns:

the closeable iterator