Uses of Interface
org.reactfx.Subscription
Packages that use Subscription
-
Uses of Subscription in org.reactfx
Classes in org.reactfx that implement SubscriptionModifier and TypeClassDescription(package private) class
(package private) class
Fields in org.reactfx declared as SubscriptionModifier and TypeFieldDescriptionstatic final Subscription
Subscription.EMPTY
private Subscription
ObservableBase.inputSubscription
private Subscription
FlatMapStream.mappedSubscription
private final Subscription
BiSubscription.s1
private final Subscription
BiSubscription.s2
private Subscription
LimitedInvocationSubscriber.subscription
private final Subscription
StreamBinding.subscription
private final Subscription[]
MultiSubscription.subscriptions
Fields in org.reactfx with type parameters of type SubscriptionModifier and TypeFieldDescriptionprivate MapHelper
<EventStream<? extends T>, Subscription> ConnectableEventSource.subscriptions
Methods in org.reactfx that return SubscriptionModifier and TypeMethodDescriptiondefault Subscription
Subscription.and
(Subscription other) Returns a new aggregate subscription whoseunsubscribe()
method callsunsubscribe()
on both this subscription andother
subscription.protected final Subscription
SuspendableBoolean.connect()
Connectable.connectTo
(EventStream<? extends T> source) Connects this connectable object tosource
event stream.ConnectableEventSource.connectTo
(EventStream<? extends T> input) static <T> Subscription
Subscription.dynamic
(javafx.collections.ObservableSet<T> elems, Function<? super T, ? extends Subscription> f) Dynamically subscribes to all elements of the given observable set.default Subscription
EventSink.feedFrom
(EventStream<? extends T> source) Starts pushing all events emitted bysource
to this event sink.default Subscription
Starts setting all events emitted by this stream as the value of the given writable value.default Subscription
Starts pushing all events emitted by this stream to the given event sink.static <T> Subscription
Subscription.multi
(Function<? super T, ? extends Subscription> f, Collection<T> elems) Subscribes to all elements of the given collection by the given function and returns an aggregate subscription that can be used to cancel all element subscriptions.static <T> Subscription
Subscription.multi
(Function<? super T, ? extends Subscription> f, T... elems) Subscribes to all elements by the given function and returns an aggregate subscription that can be used to cancel all element subscriptions.static Subscription
Subscription.multi
(Subscription... subs) Returns a new aggregate subscription whoseunsubscribe()
method callsunsubscribe()
on all arguments to this method.default Subscription
final Subscription
final Subscription
final Subscription
Returns an empty Subscription (EMPTY
).protected Subscription
AccumulateBetweenStream.observeInputs()
protected Subscription
AccumulateUntilLaterStream.observeInputs()
protected final Subscription
AccumulatingStream.observeInputs()
protected final Subscription
Await.observeInputs()
protected Subscription
AwaitLatest.observeInputs()
protected final Subscription
ConnectableEventSource.observeInputs()
protected final Subscription
DefaultEventStream.observeInputs()
protected Subscription
DistinctStream.observeInputs()
protected Subscription
EmitBothOnEachStream.observeInputs()
protected Subscription
EmitOnEachStream.observeInputs()
protected Subscription
EmitOnStream.observeInputs()
protected final Subscription
EventSource.observeInputs()
protected Subscription
FilterMapStream.observeInputs()
protected Subscription
FilterStream.observeInputs()
protected Subscription
FlatMapOptStream.observeInputs()
protected Subscription
FlatMapStream.observeInputs()
protected Subscription
HookStream.observeInputs()
protected Subscription
LatestNStream.observeInputs()
protected Subscription
MappedStream.observeInputs()
protected abstract Subscription
ObservableBase.observeInputs()
Starts observing this observable's input(s), if any.protected Subscription
RecursiveStream.observeInputs()
protected Subscription
RepeatOnStream.observeInputs()
protected Subscription
StatefulStream.observeInputs()
protected Subscription
StateStream.observeInputs()
protected final Subscription
SuccessionReducingStream.observeInputs()
protected final Subscription
SuspendableBase.observeInputs()
protected Subscription
SuspendedWhenStream.observeInputs()
protected Subscription
SuspenderStreamImpl.observeInputs()
protected final Subscription
ThenAccumulateForStream.observeInputs()
protected Subscription
ThreadBridge.observeInputs()
default Subscription
EventStream.pin()
If this stream is a compound stream lazily subscribed to its inputs, that is, subscribed to inputs only when it itself has some subscribers,pin
ning this stream causes it to stay subscribed until the pinning is revoked by callingunsubscribe()
on the returned subscription.default Subscription
Get notified every time this event stream emits a value.default Subscription
EventStream.subscribeFor
(int n, Consumer<? super T> subscriber) Subscribes to this event stream for at mostn
events.default Subscription
EventStream.subscribeForOne
(Consumer<? super T> subscriber) Shorthand forsubscribeFor(1, subscriber)
.(package private) Subscription
LimitedInvocationSubscriber.subscribeTo
(EventStream<? extends T> stream) private final Subscription
ConnectableEventSource.subscribeToInput
(EventStream<? extends T> input) InputHandler.subscribeToInput()
default Subscription
Suspendable.suspendWhen
(javafx.beans.value.ObservableValue<Boolean> condition) Methods in org.reactfx with parameters of type SubscriptionModifier and TypeMethodDescriptiondefault Subscription
Subscription.and
(Subscription other) Returns a new aggregate subscription whoseunsubscribe()
method callsunsubscribe()
on both this subscription andother
subscription.static Subscription
Subscription.multi
(Subscription... subs) Returns a new aggregate subscription whoseunsubscribe()
method callsunsubscribe()
on all arguments to this method.Method parameters in org.reactfx with type arguments of type SubscriptionModifier and TypeMethodDescriptionstatic <T> Subscription
Subscription.dynamic
(javafx.collections.ObservableSet<T> elems, Function<? super T, ? extends Subscription> f) Dynamically subscribes to all elements of the given observable set.static <T> Subscription
Subscription.multi
(Function<? super T, ? extends Subscription> f, Collection<T> elems) Subscribes to all elements of the given collection by the given function and returns an aggregate subscription that can be used to cancel all element subscriptions.static <T> Subscription
Subscription.multi
(Function<? super T, ? extends Subscription> f, T... elems) Subscribes to all elements by the given function and returns an aggregate subscription that can be used to cancel all element subscriptions.Constructors in org.reactfx with parameters of type SubscriptionModifierConstructorDescriptionBiSubscription
(Subscription s1, Subscription s2) MultiSubscription
(Subscription... subscriptions) -
Uses of Subscription in org.reactfx.collection
Methods in org.reactfx.collection that return SubscriptionModifier and TypeMethodDescriptionprotected Subscription
ListRangeReduction.connect()
protected Subscription
ListReduction.connect()
default Subscription
LiveList.observeChanges
(Consumer<? super ListChange<? extends E>> observer) static <E> Subscription
LiveList.observeChanges
(javafx.collections.ObservableList<E> list, Consumer<? super ListChange<? extends E>> observer) protected Subscription
DynamicallyMappedList.observeInputs()
protected Subscription
LiveArrayList.observeInputs()
protected Subscription
MappedList.observeInputs()
protected Subscription
MemoizationListImpl.MemoizedView.observeInputs()
protected Subscription
MemoizationListImpl.observeInputs()
protected Subscription
ValAsList.observeInputs()
default Subscription
LiveList.observeModifications
(Consumer<? super ListModification<? extends E>> observer) static <E> Subscription
LiveList.observeQuasiChanges
(javafx.collections.ObservableList<? extends E> list, LiveList.QuasiChangeObserver<? super E> observer) default Subscription
LiveList.observeQuasiChanges
(LiveList.QuasiChangeObserver<? super E> observer) default Subscription
LiveList.observeQuasiModifications
(LiveList.QuasiModificationObserver<? super E> observer) default Subscription
LiveList.pin()
-
Uses of Subscription in org.reactfx.value
Fields in org.reactfx.value declared as SubscriptionModifier and TypeFieldDescriptionprivate Subscription
VarFromVal.binding
private Subscription
FlatMapped.selectedSubscription
Methods in org.reactfx.value that return SubscriptionModifier and TypeMethodDescriptionprotected Subscription
AnimatedVal.connect()
protected final Subscription
FlatMapped.connect()
protected Subscription
MappedVal.connect()
protected Subscription
OrElse.connect()
protected Subscription
OrElseConst.connect()
protected Subscription
SimpleVar.connect()
protected abstract Subscription
ValBase.connect()
Implementation of this method should start observing inputs.protected Subscription
ValWrapper.connect()
default Subscription
Val.observeChanges
(javafx.beans.value.ChangeListener<? super T> listener) Adds a change listener and returns a Subscription that can be used to remove that listener.static <T> Subscription
Val.observeChanges
(javafx.beans.value.ObservableValue<? extends T> obs, javafx.beans.value.ChangeListener<? super T> listener) protected final Subscription
ValBase.observeInputs()
default Subscription
Val.observeInvalidations
(Consumer<? super T> oldValueObserver) static Subscription
Val.observeInvalidations
(javafx.beans.value.ObservableValue<?> obs, javafx.beans.InvalidationListener listener) default Subscription
Val.pin()