Class EventStreamBase<T>

java.lang.Object

org.reactfx.ObservableBase<Consumer<? super T>, T>

org.reactfx.EventStreamBase<T>

Type Parameters:

T - type of events emitted by this event stream.

All Implemented Interfaces:

EventStream<T>, Observable<Consumer<? super T>>, ProperEventStream<T>, ProperObservable<Consumer<? super T>, T>

Direct Known Subclasses:

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

public abstract class EventStreamBase<T>
extends ObservableBase<Consumer<? super T>, T>
implements ProperEventStream<T>

Base class for event streams.

Constructor Summary

Constructors

Constructor	Description
EventStreamBase()
EventStreamBase(NotificationAccumulator<Consumer<? super T>, T, ?> pn)

Method Summary

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 EventStream

accumulate, accumulate, accumulate, accumulateBetween, accumulateBetween, accumulateUntilLater, accumulateUntilLater, accumulateUntilLater, accumulateUntilLater, accumulateWhen, accumulateWhen, accumulative, accumulative, cast, conditionOn, conditionOnShowing, distinct, emitBothOnEach, emitOn, emitOnEach, feedTo, feedTo, filter, filter, filterMap, filterMap, flatMap, forgetful, fork, guardedBy, hook, latestN, map, mapToCompletionStage, mapToTask, onRecurseAccumulate, onRecurseAccumulate, onRecurseQueue, onRecurseReduce, onRecurseRetainLatest, or, pausable, pauseWhen, pin, queueBetween, queueUntilLater, queueUntilLater, reduceBetween, reduceSuccessions, reduceSuccessions, reduceSuccessions, reduceSuccessions, reduceSuccessions, reduceSuccessions, reduceUntilLater, reduceUntilLater, reduceWhen, reducible, repeatOn, retainLatestBetween, retainLatestUntilLater, retainLatestUntilLater, retainLatestWhen, splitBy, subscribe, subscribeFor, subscribeForOne, successionEnds, successionEnds, supply, supply, supplyCompletionStage, supplyTask, suppressible, suppressWhen, suspenderOf, thenAccumulateFor, thenAccumulateFor, thenAccumulateFor, thenAccumulateFor, thenIgnoreFor, thenIgnoreFor, thenReduceFor, thenReduceFor, thenRetainLatestFor, thenRetainLatestFor, threadBridge, threadBridgeFromFx, threadBridgeToFx, toBinding, withDefaultEvent

Methods inherited from interface Observable

addObserver, observe, removeObserver

Methods inherited from interface ProperEventStream

defaultNotificationAccumulator, emit

Methods inherited from interface ProperObservable

defaultEquals, defaultHashCode, defaultToString, notifyObservers

Constructor Details

EventStreamBase

public EventStreamBase()

EventStreamBase

EventStreamBase(NotificationAccumulator<Consumer<? super T>, T, ?> pn)