LatestNStream

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>>
```
See EventStream.latestN(int)

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 before ObservableBase.newObserver(Object) is called for the first observer.
    
    Specified by:
    
    observeInputs in class ObservableBase<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)
```