Package org.reactfx
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>
- Direct Known Subclasses:
SuspenderStreamImpl
@Experimental public abstract class SuspenderBase<O,T,S extends Suspendable> extends ObservableBase<O,T> implements Suspender<S>
-
-
Field Summary
Fields Modifier and Type Field Description private S
suspendable
-
Constructor Summary
Constructors Modifier Constructor Description protected
SuspenderBase(S suspendable)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description S
getSuspendable()
protected void
notifyObserversWhileSuspended(T notification)
Use in subclasses instead ofObservableBase.notifyObservers(Object)
in order to suspend the associated Suspendable while notifying observers.-
Methods inherited from class org.reactfx.ObservableBase
addObserver, enqueueNotifications, equals, forEachObserver, getObserverCount, hashCode, isObservingInputs, newObserver, notifyObservers, notifyObservers, observe, observeInputs, removeObserver, toString
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.reactfx.ProperObservable
defaultEquals, defaultHashCode, defaultNotificationAccumulator, defaultToString
-
-
-
-
Field Detail
-
suspendable
private final S extends Suspendable suspendable
-
-
Constructor Detail
-
SuspenderBase
protected SuspenderBase(S suspendable)
-
-
Method Detail
-
notifyObserversWhileSuspended
protected final void notifyObserversWhileSuspended(T notification)
Use in subclasses instead ofObservableBase.notifyObservers(Object)
in order to suspend the associated Suspendable while notifying observers.
-
getSuspendable
public final S getSuspendable()
- Specified by:
getSuspendable
in interfaceSuspender<O>
-
-