Package org.reactfx
Class DefaultEventStream<T>
- java.lang.Object
-
- org.reactfx.ObservableBase<java.util.function.Consumer<? super T>,T>
-
- org.reactfx.EventStreamBase<T>
-
- org.reactfx.DefaultEventStream<T>
-
- All Implemented Interfaces:
EventStream<T>
,Observable<java.util.function.Consumer<? super T>>
,ProperEventStream<T>
,ProperObservable<java.util.function.Consumer<? super T>,T>
class DefaultEventStream<T> extends EventStreamBase<T>
-
-
Field Summary
Fields Modifier and Type Field Description private boolean
emitted
private boolean
firstObserver
private T
initial
private EventStream<T>
input
private T
latestEvent
-
Constructor Summary
Constructors Constructor Description DefaultEventStream(EventStream<T> input, T initial)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
newObserver(java.util.function.Consumer<? super T> observer)
Called for each new observer.protected Subscription
observeInputs()
Starts observing this observable's input(s), if any.-
Methods inherited from class org.reactfx.ObservableBase
addObserver, enqueueNotifications, equals, forEachObserver, getObserverCount, hashCode, isObservingInputs, 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
-
input
private final EventStream<T> input
-
initial
private final T initial
-
latestEvent
private T latestEvent
-
firstObserver
private boolean firstObserver
-
emitted
private boolean emitted
-
-
Constructor Detail
-
DefaultEventStream
public DefaultEventStream(EventStream<T> input, T initial)
-
-
Method Detail
-
newObserver
protected void newObserver(java.util.function.Consumer<? super T> observer)
Description copied from class:ObservableBase
Called for each new observer. Overriding this method is a convenient way for subclasses to handle this event, for example to publish some initial events.This method is called after the
ObservableBase.observeInputs()
method.- Overrides:
newObserver
in classObservableBase<java.util.function.Consumer<? super T>,T>
-
observeInputs
protected final 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 T>,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.
-
-