org.reactfx

pack-priv Class SuspenderStreamImpl<T, S extends Suspendable>

Class Inheritance

extends SuspenderBase<Consumer<? super T>, T, S extends Suspendable>
implements SuspenderStream<T, S extends Suspendable>, ProperEventStream<T>

All Implemented Interfaces

org.reactfx.ProperEventStream, org.reactfx.ProperObservable, org.reactfx.Observable, org.reactfx.EventStream, org.reactfx.SuspenderStream, org.reactfx.Suspender

Imports

java.util.function.Consumer

Field Summary

Modifier and Type	Field and Description
private final EventStream<T>	source

Constructor Summary

Access	Constructor and Description
public	SuspenderStreamImpl(EventStream<T> source, S suspendable)

Method Summary

Modifier and Type	Method and Description
protected Subscription	observeInputs() Implements abstract org.reactfx.ObservableBase.observeInputs. Starts observing this observable's input(s), if any.

Inherited from org.reactfx.SuspenderBase:: getSuspendable notifyObserversWhileSuspended

Field Detail

source	back to summary
private final EventStream<T> source

Constructor Detail

SuspenderStreamImpl	back to summary
public SuspenderStreamImpl(EventStream<T> source, S suspendable)

Method Detail

observeInputs back to summary

observeInputs	back to summary
protected Subscription observeInputs() Implements abstract org.reactfx.ObservableBase.observeInputs. Doc from org.reactfx.ObservableBase.observeInputs. Starts observing this observable's input(s), if any. This method is called when the number of observers goes from 0 to 1. This method is called before `newObserver(Object)` is called for the first observer. Annotations @Override

protected Subscription observeInputs()

Implements abstract org.reactfx.ObservableBase.observeInputs.

Doc from org.reactfx.ObservableBase.observeInputs.

Starts observing this observable's input(s), if any. This method is called when the number of observers goes from 0 to 1. This method is called before newObserver(Object) is called for the first observer.

Annotations

@Override