delay

Delay every element passed through with a specific duration.

Timer driven stages

Signature

def delay(of: FiniteDuration, strategy: DelayOverflowStrategy = DelayOverflowStrategy.dropTail): Repr[Out]

Description

Delay every element passed through with a specific duration.

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.