Injects additional elements if the upstream does not emit for a configured amount of time. In other words, this stage attempts to maintains a base rate of emitted elements towards the downstream. If the downstream backpressures then no element is injected until downstream demand arrives. Injected elements do not accumulate during this period. Upstream elements are always preferred over injected elements.

Emits when upstream emits an element or if the upstream was idle for the configured period

Backpressures when downstream backpressures

Completes when upstream completes

Cancels when downstream cancels

public static Source<TInjected, TMat> KeepAlive<TOut, TInjected, TMat>(
	this Source<TOut, TMat> flow,
	TimeSpan timeout,
	Func<TInjected> injectElement
)
where TOut : TInjected

[<ExtensionAttribute>]
static member KeepAlive : 
        flow : Source<'TOut, 'TMat> * 
        timeout : TimeSpan * 
        injectElement : Func<'TInjected> -> Source<'TInjected, 'TMat>  when 'TOut : 'TInjected