Package org.reactfx

Class EventSource<T>

java.lang.Object

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

org.reactfx.EventStreamBase<T>

org.reactfx.EventSource<T>

Type Parameters:

T - type of values this EventSource accepts and emits.

All Implemented Interfaces:

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

public class EventSource<T>
extends EventStreamBase<T>
implements EventSink<T>

EventSource is an EventSink that serves also as an EventStream - every value pushed to EventSource is immediately emitted by it.

Constructor Summary

Constructors

Constructor	Description
EventSource()

Method Summary

Modifier and Type	Method	Description
protected final Subscription	observeInputs()	Starts observing this observable's input(s), if any.
final void	push(T value)	Make this event stream immediately emit the given value.

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.EventSink

feedFrom

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

Constructor Details

EventSource

public EventSource()

Method Details

push

public final void push(T value)

Make this event stream immediately emit the given value.

Specified by:

push in interface EventSink<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.