Class ListReduction<T>

java.lang.Object

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

org.reactfx.value.ValBase<T>

org.reactfx.collection.ListReduction<T>

All Implemented Interfaces:

javafx.beans.Observable, javafx.beans.value.ObservableValue<T>, Observable<Consumer<? super T>>, ProperObservable<Consumer<? super T>, T>, ProperVal<T>, Val<T>

Direct Known Subclasses:

ListRangeReduction

class ListReduction<T>
extends ValBase<T>

Field Summary

Fields

Modifier and Type	Field	Description
private final javafx.collections.ObservableList<T>	input
private final ToSemigroup<T,T>	monoid
private final BinaryOperator<T>	reduction
private FingerTree<T,T>	tree

Constructor Summary

Constructors

Constructor	Description
ListReduction(javafx.collections.ObservableList<T> input, BinaryOperator<T> reduction)

Method Summary

Modifier and Type	Method	Description
protected final T	computeValue()
protected Subscription	connect()	Implementation of this method should start observing inputs.
protected int	getFrom(int max)
protected int	getTo(int max)

Methods inherited from class ValBase

getValue, invalidate, newObserver, observeInputs

Methods inherited from class ObservableBase

addObserver, enqueueNotifications, equals, forEachObserver, getObserverCount, hashCode, isObservingInputs, notifyObservers, notifyObservers, observe, removeObserver, toString

Methods inherited from class Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface Observable

addObserver, observe, removeObserver

Methods inherited from interface ProperObservable

defaultEquals, defaultHashCode, defaultToString, notifyObservers

Methods inherited from interface ProperVal

defaultNotificationAccumulator

Methods inherited from interface Val

addInvalidationObserver, addListener, addListener, animate, animate, asList, asVar, changes, conditionOn, conditionOnShowing, filter, flatMap, getOpt, getOrElse, getOrSupply, getOrThrow, ifPresent, invalidations, isEmpty, isPresent, map, mapDynamic, observeChanges, observeInvalidations, orElse, orElseConst, pin, removeInvalidationObserver, removeListener, removeListener, selectVar, selectVar, suspendable, values

Field Details

input

private final javafx.collections.ObservableList<T> input

reduction

private final BinaryOperator<T> reduction

monoid

private final ToSemigroup<T,T> monoid

tree

private FingerTree<T,T> tree

Constructor Details

ListReduction

ListReduction(javafx.collections.ObservableList<T> input,
 BinaryOperator<T> reduction)

Method Details

connect

protected Subscription connect()

Description copied from class: ValBase

Implementation of this method should start observing inputs. If the value of this Val may change as a result of input change, the corresponding input observer should call ValBase.invalidate() to notify observers of this Val. By the time of calling ValBase.invalidate(), the input observer must have already updated any internal state of this Val, so that a subsequent call to ValBase.computeValue() returns the current value of this Val.

Specified by:

connect in class ValBase<T>

Returns:

Subscription that can be used to stop observing inputs.

getFrom

protected int getFrom(int max)

getTo

protected int getTo(int max)

computeValue

protected final T computeValue()

Specified by:

computeValue in class ValBase<T>