com.iamsoft.util.ui.javafx.codearea

Class SimpleEditor.AggregatedEventStream

java.lang.Object

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

org.reactfx.EventStreamBase<List<org.fxmisc.richtext.model.PlainTextChange>>

com.iamsoft.util.ui.javafx.codearea.SimpleEditor.AggregatedEventStream

All Implemented Interfaces:

org.reactfx.AwaitingEventStream<List<org.fxmisc.richtext.model.PlainTextChange>>, org.reactfx.EventStream<List<org.fxmisc.richtext.model.PlainTextChange>>, org.reactfx.Observable<Consumer<? super List<org.fxmisc.richtext.model.PlainTextChange>>>, org.reactfx.ProperEventStream<List<org.fxmisc.richtext.model.PlainTextChange>>, org.reactfx.ProperObservable<Consumer<? super List<org.fxmisc.richtext.model.PlainTextChange>>,List<org.fxmisc.richtext.model.PlainTextChange>>

Enclosing class:

SimpleEditor

public class SimpleEditor.AggregatedEventStream
extends org.reactfx.EventStreamBase<List<org.fxmisc.richtext.model.PlainTextChange>>
implements org.reactfx.AwaitingEventStream<List<org.fxmisc.richtext.model.PlainTextChange>>

A stream which collects text changes and waits for the specified time interval before emitting the changes.

Method Summary

Modifier and Type	Method and Description
javafx.beans.property.DoubleProperty	aggreagatedChangeMillis()
void	emitPendingTextChanges() Forces the propagation of any pending aggregated text changes.
boolean	isAggregationEnabled()
boolean	isPending()
boolean	isReceiving()
protected org.reactfx.Subscription	observeInputs()
javafx.beans.value.ObservableBooleanValue	pendingProperty()
javafx.beans.value.ObservableBooleanValue	receivingProperty()
void	setAggregationEnabled(boolean pEnabled)
javafx.beans.value.ObservableValue<Boolean>	suppressedProperty()

Methods inherited from class org.reactfx.ObservableBase

addObserver, enqueueNotifications, equals, forEachObserver, getObserverCount, hashCode, isObservingInputs, newObserver, notifyObservers, notifyObservers, observe, 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

Method Detail

pendingProperty

public javafx.beans.value.ObservableBooleanValue pendingProperty()

Specified by:

pendingProperty in interface org.reactfx.AwaitingEventStream<List<org.fxmisc.richtext.model.PlainTextChange>>

isPending

public boolean isPending()

Specified by:

isPending in interface org.reactfx.AwaitingEventStream<List<org.fxmisc.richtext.model.PlainTextChange>>

receivingProperty

public javafx.beans.value.ObservableBooleanValue receivingProperty()

isReceiving

public boolean isReceiving()

aggreagatedChangeMillis

public javafx.beans.property.DoubleProperty aggreagatedChangeMillis()

suppressedProperty

public javafx.beans.value.ObservableValue<Boolean> suppressedProperty()

observeInputs

protected org.reactfx.Subscription observeInputs()

Specified by:

observeInputs in class org.reactfx.ObservableBase<Consumer<? super List<org.fxmisc.richtext.model.PlainTextChange>>,List<org.fxmisc.richtext.model.PlainTextChange>>

emitPendingTextChanges

public void emitPendingTextChanges()

Forces the propagation of any pending aggregated text changes.

isAggregationEnabled

public boolean isAggregationEnabled()

setAggregationEnabled

public void setAggregationEnabled(boolean pEnabled)