default <A> SuspendableEventStream<T> |
EventStream.accumulative(java.util.function.Function<? super T,? extends A> initialTransformation,
java.util.function.BiFunction<? super A,? super T,? extends A> accumulation,
java.util.function.Function<? super A,AccumulatorSize> size,
java.util.function.Function<? super A,? extends T> head,
java.util.function.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(java.util.function.Supplier<? extends A> unit,
java.util.function.BiFunction<? super A,? super T,? extends A> accumulation,
java.util.function.Function<? super A,AccumulatorSize> size,
java.util.function.Function<? super A,? extends T> head,
java.util.function.Function<? super A,? extends A> tail) |
|
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(java.util.function.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.
|