Class ConnectableEventSource<T>

java.lang.Object

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

org.reactfx.EventStreamBase<T>

org.reactfx.ConnectableEventSource<T>

All Implemented Interfaces:

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

public final class ConnectableEventSource<T>
extends EventStreamBase<T>
implements ConnectableEventStream<T>, ConnectableEventSink<T>

Field Summary

Fields

Modifier and Type	Field	Description
private MapHelper<EventStream<? extends T>, Subscription>	subscriptions

Constructor Summary

Constructors

Constructor	Description
ConnectableEventSource()

Method Summary

Modifier and Type	Method	Description
Subscription	connectTo(EventStream<? extends T> input)	Connects this connectable object to source event stream.
protected final Subscription	observeInputs()	Starts observing this observable's input(s), if any.
final void	push(T value)
private final Subscription	subscribeToInput(EventStream<? extends T> input)

Methods inherited from class ObservableBase

addObserver, enqueueNotifications, equals, forEachObserver, getObserverCount, hashCode, isObservingInputs, newObserver, notifyObservers, notifyObservers, observe, removeObserver, toString

Methods inherited from class Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface EventSink

feedFrom

Methods inherited from interface 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 Observable

addObserver, observe, removeObserver

Methods inherited from interface ProperEventStream

defaultNotificationAccumulator, emit

Methods inherited from interface ProperObservable

defaultEquals, defaultHashCode, defaultToString, notifyObservers

Field Details

subscriptions

private MapHelper<EventStream<? extends T>, Subscription> subscriptions

Constructor Details

ConnectableEventSource

public ConnectableEventSource()

Method Details

push

public final void push(T value)

Specified by:

push in interface EventSink<T>

connectTo

public Subscription connectTo(EventStream<? extends T> input)

Description copied from interface: Connectable

Connects this connectable object to source event stream. Implementations of this method should subscribe to source lazily, i.e. only subscribe to source when necessary, e.g. when the connectable object itself is being observed (e.g. itself has at least one subscriber).

A Connectable may be connected to multiple sources at the same time.

Specified by:

connectTo in interface Connectable<T>

Parameters:

input - event stream to (lazily) connect to.

Returns:

subscription that can be used to disconnect this connectable object from source.

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.

subscribeToInput

private final Subscription subscribeToInput(EventStream<? extends T> input)