Chunk up this stream into groups of the given size, with the last group possibly smaller than requested due to end-of-stream. n must be positive, otherwise ArgumentException is thrown.

Emits when the specified number of elements has been accumulated or upstream completed

Backpressures when a group has been assembled and downstream backpressures

Completes when upstream completes

Cancels when downstream cancels

public static Flow<TIn, IEnumerable<TOut>, TMat> Grouped<TIn, TOut, TMat>(
	this Flow<TIn, TOut, TMat> flow,
	int n
)

[<ExtensionAttribute>]
static member Grouped : 
        flow : Flow<'TIn, 'TOut, 'TMat> * 
        n : int -> Flow<'TIn, IEnumerable<'TOut>, 'TMat>