Top Description Constructors Methods

org.reactfx

public abstract Class EventStreamBase<T>

Class Inheritance

extends ObservableBase<Consumer<? super T>, T>
implements ProperEventStream<T>

java.lang.Object
org.reactfx.ObservableBase
org.reactfx.EventStreamBase

All Implemented Interfaces

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

Known Direct Subclasses

org.reactfx.FilterMapStream, org.reactfx.FilterStream, org.reactfx.FlatMapStream, org.reactfx.FlatMapOptStream, org.reactfx.HookStream, org.reactfx.LatestNStream, org.reactfx.MappedStream, org.reactfx.RecursiveStream, org.reactfx.RepeatOnStream, org.reactfx.StateStream, org.reactfx.StatefulStream, org.reactfx.SuccessionReducingStream, org.reactfx.SuspendedWhenStream, org.reactfx.ThenAccumulateForStream, org.reactfx.ThreadBridge, org.reactfx.AccumulateBetweenStream, org.reactfx.AccumulateUntilLaterStream, org.reactfx.AccumulatingStream, org.reactfx.Await, org.reactfx.AwaitLatest, org.reactfx.ConnectableEventSource, org.reactfx.DefaultEventStream, org.reactfx.DistinctStream, org.reactfx.EmitBothOnEachStream, org.reactfx.EmitOnEachStream, org.reactfx.EmitOnStream, org.reactfx.EventSource

Type Parameters

<T>: type of events emitted by this event stream.

Imports

java.util.function.Consumer, org.reactfx.util.NotificationAccumulator

Base class for event streams.

Constructor Summary

Access	Constructor and Description
public	EventStreamBase()
pack-priv	EventStreamBase(NotificationAccumulator<Consumer<? super T>, T, ?> pn)

Method Summary

Inherited from org.reactfx.ObservableBase:: addObserver enqueueNotifications equals forEachObserver getObserverCount hashCode isObservingInputs newObserver notifyObservers notifyObservers observe observeInputs removeObserver toString

Constructor Detail

EventStreamBase	back to summary
public EventStreamBase()

EventStreamBase	back to summary
pack-priv EventStreamBase(NotificationAccumulator<Consumer<? super T>, T, ?> pn)