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 final S	suspendable

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

Field Details

suspendable

private final S extends Suspendable suspendable

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>