Package org.reactfx

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 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.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 org.reactfx.Observable

addObserver, observe, removeObserver

Methods inherited from interface org.reactfx.ProperEventStream

defaultNotificationAccumulator, emit

Methods inherited from interface org.reactfx.ProperObservable

defaultEquals, defaultHashCode, defaultToString, notifyObservers

Constructor Details

EventStreamBase

public EventStreamBase()

EventStreamBase

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