aggregateWithBoundary
Aggregate and emit until custom boundary condition met.
Signature
Source.aggregateWithBoundarySource.aggregateWithBoundary Flow.aggregateWithBoundaryFlow.aggregateWithBoundary
Description
This operator can be customized into a broad class of aggregate/group/fold operators, based on custom state or timer conditions.
This operator adheres to the ActorAttributes.SupervisionStrategy attribute for exceptions thrown by allocate, aggregate, harvest, or timer predicate functions. On Supervision.Stop the stream fails; on Supervision.Resume and Supervision.Restart the failing element or aggregate is dropped and the stream continues.
Reactive Streams semantics
emits when the aggregation function decides the aggregate is complete or the timer function returns true
backpressures when downstream backpressures and the aggregate is complete
completes when upstream completes and the last aggregate has been emitted downstream
cancels when downstream cancels