Class LatestNStream<T>

java.lang.Object

org.reactfx.ObservableBase<Consumer<? super List<T>>, List<T>>

org.reactfx.EventStreamBase<List<T>>

org.reactfx.LatestNStream<T>

All Implemented Interfaces:

EventStream<List<T>>, Observable<Consumer<? super List<T>>>, ProperEventStream<List<T>>, ProperObservable<Consumer<? super List<T>>, List<T>>

class LatestNStream<T>
extends EventStreamBase<List<T>>

See EventStream.latestN(int)

Field Summary

Fields

Modifier and Type	Field	Description
private List<T>	concatView
private List<T>	first
private final int	n
private List<T>	second
private final EventStream<T>	source

Constructor Summary

Constructors

Constructor	Description
LatestNStream(EventStream<T> source, int n)

Method Summary

Modifier and Type	Method	Description
protected Subscription	observeInputs()	Starts observing this observable's input(s), if any.
private void	onEvent(T event)

Methods inherited from class ObservableBase

addObserver, enqueueNotifications, equals, forEachObserver, getObserverCount, hashCode, isObservingInputs, newObserver, notifyObservers, notifyObservers, observe, removeObserver, toString

Methods inherited from class Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface EventStream

accumulate, accumulate, accumulate, accumulateBetween, accumulateBetween, accumulateUntilLater, accumulateUntilLater, accumulateUntilLater, accumulateUntilLater, accumulateWhen, accumulateWhen, accumulative, accumulative, cast, conditionOn, conditionOnShowing, distinct, emitBothOnEach, emitOn, emitOnEach, feedTo, feedTo, filter, filter, filterMap, filterMap, flatMap, forgetful, fork, guardedBy, hook, latestN, map, mapToCompletionStage, mapToTask, onRecurseAccumulate, onRecurseAccumulate, onRecurseQueue, onRecurseReduce, onRecurseRetainLatest, or, pausable, pauseWhen, pin, queueBetween, queueUntilLater, queueUntilLater, reduceBetween, reduceSuccessions, reduceSuccessions, reduceSuccessions, reduceSuccessions, reduceSuccessions, reduceSuccessions, reduceUntilLater, reduceUntilLater, reduceWhen, reducible, repeatOn, retainLatestBetween, retainLatestUntilLater, retainLatestUntilLater, retainLatestWhen, splitBy, subscribe, subscribeFor, subscribeForOne, successionEnds, successionEnds, supply, supply, supplyCompletionStage, supplyTask, suppressible, suppressWhen, suspenderOf, thenAccumulateFor, thenAccumulateFor, thenAccumulateFor, thenAccumulateFor, thenIgnoreFor, thenIgnoreFor, thenReduceFor, thenReduceFor, thenRetainLatestFor, thenRetainLatestFor, threadBridge, threadBridgeFromFx, threadBridgeToFx, toBinding, withDefaultEvent

Methods inherited from interface Observable

addObserver, observe, removeObserver

Methods inherited from interface ProperEventStream

defaultNotificationAccumulator, emit

Methods inherited from interface ProperObservable

defaultEquals, defaultHashCode, defaultToString, notifyObservers

Field Details

source

private final EventStream<T> source

n

private final int n

first

private List<T> first

second

private List<T> second

concatView

private List<T> concatView

Constructor Details

LatestNStream

public LatestNStream(EventStream<T> source,
 int n)

Method Details

observeInputs

protected Subscription observeInputs()

Description copied from class: ObservableBase

Starts observing this observable's input(s), if any. This method is called when the number of observers goes from 0 to 1. This method is called before ObservableBase.newObserver(Object) is called for the first observer.

Specified by:

observeInputs in class ObservableBase<Consumer<? super List<T>>, List<T>>

Returns:

subscription used to stop observing inputs. The subscription is unsubscribed (i.e. input observation stops) when the number of observers goes down to 0.

onEvent

private void onEvent(T event)