Terminate processing (and cancel the upstream publisher) after the given duration. Due to input buffering some elements may have been requested from upstream publishers that will then not be processed downstream of this step. Note that this can be combined with TakeTIn, TOut, TMat(FlowTIn, TOut, TMat, Int64) to limit the number of elements within the duration.

Emits when an upstream element arrives

Backpressures when downstream backpressures

Completes when upstream completes or timer fires

Cancels when downstream cancels or timer fires

public static Flow<TIn, TOut, TMat> TakeWithin<TIn, TOut, TMat>(
	this Flow<TIn, TOut, TMat> flow,
	TimeSpan duration
)

[<ExtensionAttribute>]
static member TakeWithin : 
        flow : Flow<'TIn, 'TOut, 'TMat> * 
        duration : TimeSpan -> Flow<'TIn, 'TOut, 'TMat>