ix.internal.operators

Class ToIterable<T>

java.lang.Object

ix.internal.util.ObservableToIterableAdapter<T,T>

ix.internal.operators.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.

Field Summary

Fields inherited from class ix.internal.util.ObservableToIterableAdapter

observable

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected ObserverToIteratorSink<T,T>	run(rx.Subscription 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 ix.internal.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(rx.Observable<? extends T> observable)

Constructor.

Parameters:

observable - the observable to convert

Method Detail

run

protected ObserverToIteratorSink<T,T> run(rx.Subscription 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 close handle

Returns:

the closeable iterator