Package org.reactfx
Class ConnectableEventSource<T>
- java.lang.Object
-
- org.reactfx.ObservableBase<java.util.function.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<java.util.function.Consumer<? super T>>
,ProperEventStream<T>
,ProperObservable<java.util.function.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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Subscription
connectTo(EventStream<? extends T> input)
Connects this connectable object tosource
event stream.protected Subscription
observeInputs()
Starts observing this observable's input(s), if any.void
push(T value)
private Subscription
subscribeToInput(EventStream<? extends T> input)
-
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
-
subscriptions
private MapHelper<EventStream<? extends T>,Subscription> subscriptions
-
-
Method Detail
-
connectTo
public Subscription connectTo(EventStream<? extends T> input)
Description copied from interface:Connectable
Connects this connectable object tosource
event stream. Implementations of this method should subscribe tosource
lazily, i.e. only subscribe tosource
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 interfaceConnectable<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 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.
-
subscribeToInput
private final Subscription subscribeToInput(EventStream<? extends T> input)
-
-