Apply a sliding window over the stream and return the windows as groups of elements, with the last group possibly smaller than requested due to end-of-stream. n must be positive, otherwise IllegalArgumentException is thrown. step must be positive, otherwise IllegalArgumentException is thrown.

Emits when enough elements have been collected within the window or upstream completed

Backpressures when a window has been assembled and downstream backpressures

Completes when upstream completes

Cancels when downstream cancels

public static Flow<TIn, IEnumerable<TOut>, TMat> Sliding<TIn, TOut, TMat>(
	this Flow<TIn, TOut, TMat> flow,
	int n,
	int step = 1
)

[<ExtensionAttribute>]
static member Sliding : 
        flow : Flow<'TIn, 'TOut, 'TMat> * 
        n : int * 
        ?step : int 
(* Defaults:
        let _step = defaultArg step 1
*)
-> Flow<'TIn, IEnumerable<'TOut>, 'TMat>