T - the element type.public class Next<T> extends ObservableToIterableAdapter<T,T>
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.
observable| Constructor and Description |
|---|
Next(Observable<? extends T> observable)
Constructor.
|
| 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.
|
iteratorpublic Next(@Nonnull
Observable<? extends T> observable)
observable - the source obserable.@Nonnull protected ObserverToIteratorSink<T,T> run(@Nonnull java.io.Closeable handle)
ObservableToIterableAdapterrun in class ObservableToIterableAdapter<T,T>handle - the closea handle