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 SubFlow<IEnumerable<TOut>, TMat, TClosed> Grouped<TOut, TMat, TClosed>(
	this SubFlow<TOut, TMat, TClosed> flow,
	int n
)

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