Package org.reactfx
Class LatestNStream<T>
- java.lang.Object
-
- org.reactfx.ObservableBase<java.util.function.Consumer<? super T>,T>
-
- org.reactfx.EventStreamBase<java.util.List<T>>
-
- org.reactfx.LatestNStream<T>
-
- All Implemented Interfaces:
EventStream<java.util.List<T>>
,Observable<java.util.function.Consumer<? super java.util.List<T>>>
,ProperEventStream<java.util.List<T>>
,ProperObservable<java.util.function.Consumer<? super java.util.List<T>>,java.util.List<T>>
class LatestNStream<T> extends EventStreamBase<java.util.List<T>>
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.List<T>
concatView
private java.util.List<T>
first
private int
n
private java.util.List<T>
second
private EventStream<T>
source
-
Constructor Summary
Constructors Constructor Description LatestNStream(EventStream<T> source, int n)
-
Method Summary
All Methods Instance Methods Concrete Methods 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 org.reactfx.ObservableBase
addObserver, enqueueNotifications, equals, forEachObserver, getObserverCount, hashCode, isObservingInputs, newObserver, notifyObservers, notifyObservers, observe, removeObserver, toString
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.reactfx.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 org.reactfx.Observable
addObserver, observe, removeObserver
-
Methods inherited from interface org.reactfx.ProperEventStream
defaultNotificationAccumulator, emit
-
Methods inherited from interface org.reactfx.ProperObservable
defaultEquals, defaultHashCode, defaultToString, notifyObservers
-
-
-
-
Field Detail
-
source
private final EventStream<T> source
-
n
private final int n
-
first
private java.util.List<T> first
-
second
private java.util.List<T> second
-
concatView
private java.util.List<T> concatView
-
-
Constructor Detail
-
LatestNStream
public LatestNStream(EventStream<T> source, int n)
-
-
Method Detail
-
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 beforeObservableBase.newObserver(Object)
is called for the first observer.- Specified by:
observeInputs
in classObservableBase<java.util.function.Consumer<? super java.util.List<T>>,java.util.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)
-
-