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 -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionfinal S
protected final 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 Details
-
suspendable
-
-
Constructor Details
-
SuspenderBase
-
-
Method Details
-
notifyObserversWhileSuspended
Use in subclasses instead ofObservableBase.notifyObservers(Object)
in order to suspend the associated Suspendable while notifying observers. -
getSuspendable
- Specified by:
getSuspendable
in interfaceSuspender<O>
-