Uses of Interface
org.reactfx.Subscription
-
Packages that use Subscription Package Description org.reactfx org.reactfx.collection org.reactfx.value -
-
Uses of Subscription in org.reactfx
Classes in org.reactfx that implement Subscription Modifier and Type Class Description (package private) class
BiSubscription
(package private) class
MultiSubscription
Fields in org.reactfx declared as Subscription Modifier and Type Field Description static Subscription
Subscription. EMPTY
private Subscription
ObservableBase. inputSubscription
private Subscription
FlatMapStream. mappedSubscription
private Subscription
BiSubscription. s1
private Subscription
BiSubscription. s2
private Subscription
LimitedInvocationSubscriber. subscription
private Subscription
StreamBinding. subscription
private Subscription[]
MultiSubscription. subscriptions
Fields in org.reactfx with type parameters of type Subscription Modifier and Type Field Description private MapHelper<EventStream<? extends T>,Subscription>
ConnectableEventSource. subscriptions
Methods in org.reactfx that return Subscription Modifier and Type Method Description default Subscription
Subscription. and(Subscription other)
Returns a new aggregate subscription whoseunsubscribe()
method callsunsubscribe()
on both this subscription andother
subscription.protected Subscription
SuspendableBoolean. connect()
Subscription
Connectable. connectTo(EventStream<? extends T> source)
Connects this connectable object tosource
event stream.Subscription
ConnectableEventSource. connectTo(EventStream<? extends T> input)
static <T> Subscription
Subscription. dynamic(javafx.collections.ObservableSet<T> elems, java.util.function.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
EventStream. feedTo(javafx.beans.value.WritableValue<? super T> dest)
Starts setting all events emitted by this stream as the value of the given writable value.default Subscription
EventStream. feedTo(EventSink<? super T> sink)
Starts pushing all events emitted by this stream to the given event sink.static <T> Subscription
Subscription. multi(java.util.function.Function<? super T,? extends Subscription> f, java.util.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(java.util.function.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
Observable. observe(O observer)
Subscription
ObservableBase. observe(O observer)
Subscription
ProxyObservable. observe(O observer)
Subscription
RigidObservable. observe(O observer)
Returns an empty Subscription (EMPTY
).protected Subscription
AccumulateBetweenStream. observeInputs()
protected Subscription
AccumulateUntilLaterStream. observeInputs()
protected Subscription
AccumulatingStream. observeInputs()
protected Subscription
Await. observeInputs()
protected Subscription
AwaitLatest. observeInputs()
protected Subscription
ConnectableEventSource. observeInputs()
protected Subscription
DefaultEventStream. observeInputs()
protected Subscription
DistinctStream. observeInputs()
protected Subscription
EmitBothOnEachStream. observeInputs()
protected Subscription
EmitOnEachStream. observeInputs()
protected Subscription
EmitOnStream. observeInputs()
protected 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 Subscription
SuccessionReducingStream. observeInputs()
protected Subscription
SuspendableBase. observeInputs()
protected Subscription
SuspendedWhenStream. observeInputs()
protected Subscription
SuspenderStreamImpl. observeInputs()
protected 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
EventStream. subscribe(java.util.function.Consumer<? super T> subscriber)
Get notified every time this event stream emits a value.default Subscription
EventStream. subscribeFor(int n, java.util.function.Consumer<? super T> subscriber)
Subscribes to this event stream for at mostn
events.default Subscription
EventStream. subscribeForOne(java.util.function.Consumer<? super T> subscriber)
Shorthand forsubscribeFor(1, subscriber)
.(package private) Subscription
LimitedInvocationSubscriber. subscribeTo(EventStream<? extends T> stream)
private Subscription
ConnectableEventSource. subscribeToInput(EventStream<? extends T> input)
Subscription
InputHandler. subscribeToInput()
default Subscription
Suspendable. suspendWhen(javafx.beans.value.ObservableValue<java.lang.Boolean> condition)
Methods in org.reactfx with parameters of type Subscription Modifier and Type Method Description default 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 Subscription Modifier and Type Method Description static <T> Subscription
Subscription. dynamic(javafx.collections.ObservableSet<T> elems, java.util.function.Function<? super T,? extends Subscription> f)
Dynamically subscribes to all elements of the given observable set.static <T> Subscription
Subscription. multi(java.util.function.Function<? super T,? extends Subscription> f, java.util.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(java.util.function.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 Subscription Constructor Description BiSubscription(Subscription s1, Subscription s2)
MultiSubscription(Subscription... subscriptions)
-
Uses of Subscription in org.reactfx.collection
Methods in org.reactfx.collection that return Subscription Modifier and Type Method Description protected Subscription
ListRangeReduction. connect()
protected Subscription
ListReduction. connect()
default Subscription
LiveList. observeChanges(java.util.function.Consumer<? super ListChange<? extends E>> observer)
static <E> Subscription
LiveList. observeChanges(javafx.collections.ObservableList<E> list, java.util.function.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(java.util.function.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 Subscription Modifier and Type Field Description private Subscription
VarFromVal. binding
private Subscription
FlatMapped. selectedSubscription
Methods in org.reactfx.value that return Subscription Modifier and Type Method Description protected Subscription
AnimatedVal. connect()
protected 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 Subscription
ValBase. observeInputs()
default Subscription
Val. observeInvalidations(java.util.function.Consumer<? super T> oldValueObserver)
static Subscription
Val. observeInvalidations(javafx.beans.value.ObservableValue<?> obs, javafx.beans.InvalidationListener listener)
default Subscription
Val. pin()
-