Top Inners Methods
org.reactfx.util

public Interface AccumulationFacility<T, A>

Known Direct Subinterfaces
org.reactfx.util.AccumulationFacility.IllegalAccumulation, org.reactfx.util.AccumulationFacility.HomotypicAccumulation, org.reactfx.util.AccumulationFacility.Queuing, org.reactfx.util.AccumulationFacility.ListChangeAccumulation
Known Direct Implementers
org.reactfx.util.NotificationAccumulatorBase
Imports
java.util.Deque, .LinkedList, org.reactfx.collection.ListChangeAccumulator, .ListModificationSequence, .QuasiListChange

Nested and Inner Type Summary

Modifier and TypeClass and Description
public static interface
public static interface
public static interface
public static interface
public static interface
public static interface
public static interface

Method Summary

Modifier and TypeMethod and Description
public A
public A
reduce(A accum, T value)

Method Detail

initialAccumulatorback to summary
public A initialAccumulator(T value)
reduceback to summary
public A reduce(A accum, T value)
org.reactfx.util back to summary

public Interface AccumulationFacility.HomotypicAccumulation<T>

extends AccumulationFacility<T, T>
Known Direct Subinterfaces
org.reactfx.util.AccumulationFacility.NoAccumulation, org.reactfx.util.AccumulationFacility.RetainLatest, org.reactfx.util.AccumulationFacility.RetainOldest
Known Direct Implementers
org.reactfx.util.AbstractReducingStreamNotifications

Method Summary

Modifier and TypeMethod and Description
public default T
Inherited from org.reactfx.util.AccumulationFacility:
reduce

Method Detail

initialAccumulatorback to summary
public default T initialAccumulator(T value)

Implements org.reactfx.util.AccumulationFacility.initialAccumulator.

Annotations
@Override
org.reactfx.util back to summary

public Interface AccumulationFacility.IllegalAccumulation<T, A>

extends AccumulationFacility<T, A>
Known Direct Subinterfaces
org.reactfx.util.AccumulationFacility.NoAccumulation

Method Summary

Modifier and TypeMethod and Description
public default A
Inherited from org.reactfx.util.AccumulationFacility:
initialAccumulator

Method Detail

reduceback to summary
public default A reduce(A accum, T value)

Implements org.reactfx.util.AccumulationFacility.reduce.

Annotations
@Override
org.reactfx.util back to summary

public Interface AccumulationFacility.ListChangeAccumulation<E>

extends AccumulationFacility<QuasiListChange<? extends E>, ListModificationSequence<E>>
Known Direct Implementers
org.reactfx.util.ListNotifications

Method Summary

Modifier and TypeMethod and Description
public default ListModificationSequence<E>
public default ListChangeAccumulator<E>

Method Detail

initialAccumulatorback to summary
public default ListModificationSequence<E> initialAccumulator(QuasiListChange<? extends E> value)

Implements org.reactfx.util.AccumulationFacility.initialAccumulator.

Annotations
@Override
reduceback to summary
public default ListChangeAccumulator<E> reduce(ListModificationSequence<E> accum, QuasiListChange<? extends E> value)

Implements org.reactfx.util.AccumulationFacility.reduce.

Annotations
@Override
org.reactfx.util back to summary

public Interface AccumulationFacility.NoAccumulation<T>

extends AccumulationFacility.IllegalAccumulation<T, T>, AccumulationFacility.HomotypicAccumulation<T>
Known Direct Implementers
org.reactfx.util.NonAccumulativeStreamNotifications

Method Summary

Inherited from org.reactfx.util.AccumulationFacility.HomotypicAccumulation:
initialAccumulator
Inherited from org.reactfx.util.AccumulationFacility.IllegalAccumulation:
reduce
org.reactfx.util back to summary

public Interface AccumulationFacility.Queuing<T>

extends AccumulationFacility<T, Deque<T>>
Known Direct Implementers
org.reactfx.util.QueuingStreamNotifications

Method Summary

Modifier and TypeMethod and Description
public default Deque<T>
public default Deque<T>

Method Detail

initialAccumulatorback to summary
public default Deque<T> initialAccumulator(T value)

Implements org.reactfx.util.AccumulationFacility.initialAccumulator.

Annotations
@Override
reduceback to summary
public default Deque<T> reduce(Deque<T> accum, T value)

Implements org.reactfx.util.AccumulationFacility.reduce.

Annotations
@Override
org.reactfx.util back to summary

public Interface AccumulationFacility.RetainLatest<T>

extends AccumulationFacility.HomotypicAccumulation<T>
Known Direct Implementers
org.reactfx.util.RetainLatestStreamNotifications

Method Summary

Modifier and TypeMethod and Description
public default T
Inherited from org.reactfx.util.AccumulationFacility.HomotypicAccumulation:
initialAccumulator

Method Detail

reduceback to summary
public default T reduce(T accum, T value)

Implements org.reactfx.util.AccumulationFacility.reduce.

Annotations
@Override
org.reactfx.util back to summary

public Interface AccumulationFacility.RetainOldest<T>

extends AccumulationFacility.HomotypicAccumulation<T>
Known Direct Implementers
org.reactfx.util.RetailOldestValNotifications

Method Summary

Modifier and TypeMethod and Description
public default T
Inherited from org.reactfx.util.AccumulationFacility.HomotypicAccumulation:
initialAccumulator

Method Detail

reduceback to summary
public default T reduce(T accum, T value)

Implements org.reactfx.util.AccumulationFacility.reduce.

Annotations
@Override