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

Fields in org.reactfx declared as Subscription

Modifier and Type	Field	Description
static final Subscription	Subscription.EMPTY

Methods in org.reactfx that return Subscription

Modifier and Type	Method	Description
default Subscription	Subscription.and(Subscription other)	Returns a new aggregate subscription whose Subscription.unsubscribe() method calls unsubscribe() on both this subscription and other subscription.
Subscription	Connectable.connectTo(EventStream<? extends T> source)	Connects this connectable object to source event stream.
Subscription	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 by source 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(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 whose Subscription.unsubscribe() method calls unsubscribe() on all arguments to this method.
default Subscription	Observable.observe(O observer)
final Subscription	ObservableBase.observe(O observer)
final Subscription	ProxyObservable.observe(O observer)
final Subscription	RigidObservable.observe(O observer)	Returns an empty Subscription (Subscription.EMPTY).
protected final Subscription	ConnectableEventSource.observeInputs()
protected final Subscription	EventSource.observeInputs()
protected abstract Subscription	ObservableBase.observeInputs()	Starts observing this observable's input(s), if any.
protected final Subscription	SuspendableBase.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, pinning this stream causes it to stay subscribed until the pinning is revoked by calling unsubscribe() on the returned subscription.
default Subscription	EventStream.subscribe(Consumer<? super T> subscriber)	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 most n events.
default Subscription	EventStream.subscribeForOne(Consumer<? super T> subscriber)	Shorthand for subscribeFor(1, subscriber).
default Subscription	Suspendable.suspendWhen(javafx.beans.value.ObservableValue<Boolean> condition)	Arranges to suspend this Suspendable whenever condition is true.

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 whose Subscription.unsubscribe() method calls unsubscribe() on both this subscription and other subscription.
static Subscription	Subscription.multi(Subscription... subs)	Returns a new aggregate subscription whose Subscription.unsubscribe() method calls unsubscribe() 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, 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.

Uses of Subscription in org.reactfx.collection

Methods in org.reactfx.collection that return Subscription

Modifier and Type	Method	Description
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	LiveArrayList.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

Methods in org.reactfx.value that return Subscription

Modifier and Type	Method	Description
protected abstract Subscription	ValBase.connect()	Implementation of this method should start observing inputs.
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()