delayWith

Delay every element passed through with a duration that can be controlled dynamically.

Timer driven operators

Signature

def delayWith(delayStrategySupplier: () => DelayStrategy[Out], overFlowStrategy: DelayOverflowStrategy): Repr[Out]

Description

Delay every element passed through with a duration that can be controlled dynamically, individually for each elements (via the DelayStrategy).

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

Found an error in this documentation? The source code for this page can be found here. Please feel free to edit and contribute a pull request.