hu.akarnokd.reactive4java.reactive

Class MostRecent<T>

java.lang.Object

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

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

Type Parameters:

T - the element type

All Implemented Interfaces:

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

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

Samples the latest T value coming from the source observable or the initial value when no messages arrived so far. If the producer and consumer run on different speeds, the consumer might receive the same value multiple times. The iterable sequence terminates if the source finishes or returns an error.

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

Modifier and Type	Field and Description
protected T	initialValue The initial value to have.

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

observable

Constructor Summary

Constructors

Constructor and Description
MostRecent(Observable<? extends T> observable, T initialValue) 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

Field Detail

initialValue

protected final T initialValue

The initial value to have.

Constructor Detail

MostRecent

public MostRecent(@Nonnull
                  Observable<? extends T> observable,
                  T initialValue)

Constructor.

Parameters:

observable - the source observable

initialValue - the initial value

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