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

Class SimpleEditor.AggregatedEventStream

java.lang.Object
org.reactfx.ObservableBase<Consumer<? super List<org.fxmisc.richtext.model.PlainTextChange>>,List<org.fxmisc.richtext.model.PlainTextChange>>
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.

  • Property Summary

    Properties
    Type
    Property
    Description
    javafx.beans.value.ObservableBooleanValue
    pending
     
    javafx.beans.value.ObservableBooleanValue
    receiving
     
    javafx.beans.value.ObservableValue<Boolean>
    suppressed
     

  • Method Summary

    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 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

  • Property Details

    • pending

      public javafx.beans.value.ObservableBooleanValue pendingProperty
      Specified by:
      pendingProperty in interface org.reactfx.AwaitingEventStream<List<org.fxmisc.richtext.model.PlainTextChange>>
      See Also:

    • receiving

      public javafx.beans.value.ObservableBooleanValue receivingProperty
      See Also:

    • suppressed

      public javafx.beans.value.ObservableValue<Boolean> suppressedProperty
      See Also:

  • Method Details

    • pendingProperty

      public javafx.beans.value.ObservableBooleanValue pendingProperty()
      Specified by:
      pendingProperty in interface org.reactfx.AwaitingEventStream<List<org.fxmisc.richtext.model.PlainTextChange>>
      Returns:
      the pending property

    • 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()
      Returns:
      the receiving property

    • isReceiving

      public boolean isReceiving()

    • aggreagatedChangeMillis

      public javafx.beans.property.DoubleProperty aggreagatedChangeMillis()

    • suppressedProperty

      public javafx.beans.value.ObservableValue<Boolean> suppressedProperty()
      Returns:
      the suppressed property

    • 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)