delayWith
Delay every element passed through with a duration that can be controlled dynamically.
Signature
Source.delayWithSource.delayWith Flow.delayWithFlow.delayWith
Description
Delay every element passed through with a duration that can be controlled dynamically, individually for each elements (via the DelayStrategy).
This operator adheres to the ActorAttributes.SupervisionStrategy attribute. On Supervision.Resume the offending element is dropped; on Supervision.Restart the delay strategy is recreated from the supplier (already-buffered elements keep their delays).
emits there is a pending element in the buffer and configured time for this element elapsed
backpressures differs, depends on OverflowStrategy set
completes when upstream completes and buffered elements has been drained