Package org.reactfx

Class DefaultEventStream<T>

java.lang.Object

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

org.reactfx.EventStreamBase<T>

org.reactfx.DefaultEventStream<T>

All Implemented Interfaces:

EventStream<T>, Observable<Consumer<? super T>>, ProperEventStream<T>, ProperObservable<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 final T	initial
private final EventStream<T>	input
private T	latestEvent

Constructor Summary

Constructors

Constructor	Description
DefaultEventStream(EventStream<T> input, T initial)

Method Summary

Modifier and Type	Method	Description
protected void	newObserver(Consumer<? super T> observer)	Called for each new observer.
protected final 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 Details

input

private final EventStream<T> input

initial

private final T initial

latestEvent

private T latestEvent

firstObserver

private boolean firstObserver

emitted

private boolean emitted

Constructor Details

DefaultEventStream

public DefaultEventStream(EventStream<T> input,
 T initial)

Method Details

newObserver

protected void newObserver(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 class ObservableBase<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 before ObservableBase.newObserver(Object) is called for the first observer.

Specified by:

observeInputs in class ObservableBase<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.