hu.akarnokd.reactive4java.reactive

Class Next<T>

java.lang.Object

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

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

Type Parameters:

T - the element type.

All Implemented Interfaces:

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

public class Next<T>
extends ObservableToIterableAdapter<T,T>

Returns an iterable sequence which blocks until an element becomes available from the source. The iterable's (has)next() call is paired up with the observer's next() call, therefore, values might be skipped if the iterable is not on its (has)next() call at the time of reception.

The returned iterator will throw an UnsupportedOperationException for its remove() method.

Exception semantics: in case of exception received, the source is disconnected and the exception is rethrown from the iterator's next method as a wrapped RuntimeException if necessary.

Since:

0.97

Field Summary

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

observable

Constructor Summary

Constructors

Constructor and Description
Next(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

Next

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

Constructor.

Parameters:

observable - the source obserable.

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