delay

Delay every element passed through with a specific duration.

Timer driven operators

Signature

Source.delaySource.delay Flow.delayFlow.delay

Description

Delay every element passed through with a specific duration.

Reactive Streams semantics

emits when there is a pending element in the buffer and configured time for this element elapsed

backpressures differs, depends on DelayOverflowStrategy set

completes when upstream completes and buffered elements have been drained