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 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 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 whose Subscription.unsubscribe() method calls unsubscribe() on both this subscription and other subscription.
protected final Subscription	SuspendableBoolean.connect()
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 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, 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).
(package private) Subscription	LimitedInvocationSubscriber.subscribeTo(EventStream<? extends T> stream)
private final Subscription	ConnectableEventSource.subscribeToInput(EventStream<? extends T> input)
Subscription	InputHandler.subscribeToInput()
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.

Constructors in org.reactfx with parameters of type Subscription

Modifier	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(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 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 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()