Shifts elements emission in time by a specified amount. It allows to store elements in internal buffer while waiting for next element to be emitted. Depending on the defined DelayOverflowStrategy it might drop elements or backpressure the upstream if there is no space available in the buffer. Delay precision is 10ms to avoid unnecessary timer scheduling cycles Internal buffer has default capacity 16. You can set buffer size by calling CreateInputBuffer(Int32, Int32)

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

* EmitEarly - strategy do not wait to emit element if buffer is full

Backpressures when depending on OverflowStrategy

* Backpressure - backpressures when buffer is full

* DropHead, DropTail, DropBuffer - never backpressures

* Fail - fails the stream if buffer gets full

Completes when upstream completes and buffered elements has been drained

Cancels when downstream cancels

public static Source<TOut, TMat> Delay<TOut, TMat>(
	this Source<TOut, TMat> flow,
	TimeSpan of,
	Nullable<DelayOverflowStrategy> strategy = null
)

[<ExtensionAttribute>]
static member Delay : 
        flow : Source<'TOut, 'TMat> * 
        of : TimeSpan * 
        ?strategy : Nullable<DelayOverflowStrategy> 
(* Defaults:
        let _strategy = defaultArg strategy null
*)
-> Source<'TOut, 'TMat>