hu.akarnokd.reactive4java.reactive

Class Latest<T>

java.lang.Object

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

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

Type Parameters:

T - the type of the values

All Implemented Interfaces:

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

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

Returns an iterable sequence which returns the latest element from the observable sequence, consuming it only once.

Note that it is possible one doesn't receive the last value of a fixed-length observable sequence in case the last next() call is is quickly followed by a finish() event.

The returned iterator throws UnsupportedOperationException for its remove() method.

Since:

0.97

Field Summary

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

observable

Constructor Summary

Constructors

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

Latest

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

Constructor.

Parameters:

observable - the source sequence

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