Uses of Interface
org.reactfx.SuspendableEventStream

Packages that use SuspendableEventStream

Package	Description
org.reactfx

Uses of SuspendableEventStream in org.reactfx

Methods in org.reactfx that return SuspendableEventStream

Modifier and Type	Method	Description
default <A> SuspendableEventStream<T>	EventStream.accumulative(Function<? super T, ? extends A> initialTransformation, BiFunction<? super A, ? super T, ? extends A> accumulation, Function<? super A, AccumulatorSize> size, Function<? super A, ? extends T> head, Function<? super A, ? extends A> tail)	Returns a suspendable event stream that, when suspended, accumulates incoming events to a cumulative value of type A.
default <A> SuspendableEventStream<T>	EventStream.accumulative(Supplier<? extends A> unit, BiFunction<? super A, ? super T, ? extends A> accumulation, Function<? super A, AccumulatorSize> size, Function<? super A, ? extends T> head, Function<? super A, ? extends A> tail)	A variation on EventStream.accumulative(Function, BiFunction, Function, Function, Function) to use when it is more convenient to provide a unit element of the accumulation than to transform the initial event to a cumulative value.
default SuspendableEventStream<T>	EventStream.forgetful()	Returns a suspendable event stream that, when suspended, forgets all but the latest event emitted by this event stream.
default SuspendableEventStream<T>	EventStream.pausable()	Returns a suspendable event stream that, when suspended, stores the events emitted by this event stream and emits them when the returned stream's emission is resumed.
default SuspendableEventStream<T>	EventStream.reducible(BinaryOperator<T> reduction)	Returns a suspendable event stream that, when suspended, reduces incoming events by the given reduction function into one.
default SuspendableEventStream<T>	EventStream.suppressible()	Returns a suspendable event stream that, when suspended, suppresses any events emitted by this event stream.