Module com.iamsoft.util.ui
Package com.iamsoft.util.ui.javafx.codearea

Class 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

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method 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 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)