Class SuspenderBase<O, T, S extends Suspendable>

java.lang.Object

org.reactfx.ObservableBase<O,T>

org.reactfx.SuspenderBase<O,T,S>

All Implemented Interfaces:

Observable<O>, ProperObservable<O,T>, Suspender<S>

@Experimental
public abstract class SuspenderBase<O, T, S extends Suspendable>
extends ObservableBase<O,T>
implements Suspender<S>

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SuspenderBase(S suspendable)

Method Summary

Modifier and Type	Method	Description
final S	getSuspendable()
protected final void	notifyObserversWhileSuspended(T notification)	Use in subclasses instead of ObservableBase.notifyObservers(Object) in order to suspend the associated Suspendable while notifying observers.

Methods inherited from class ObservableBase

addObserver, enqueueNotifications, equals, forEachObserver, getObserverCount, hashCode, isObservingInputs, newObserver, notifyObservers, notifyObservers, observe, observeInputs, removeObserver, toString

Methods inherited from class Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface ProperObservable

defaultEquals, defaultHashCode, defaultNotificationAccumulator, defaultToString

Constructor Details

SuspenderBase

protected SuspenderBase(S suspendable)

Method Details

notifyObserversWhileSuspended

protected final void notifyObserversWhileSuspended(T notification)

Use in subclasses instead of ObservableBase.notifyObservers(Object) in order to suspend the associated Suspendable while notifying observers.

getSuspendable

public final S getSuspendable()

Specified by:

getSuspendable in interface Suspender<O>