sliding

Provide a sliding window over the incoming stream and pass the windows as groups of elements downstream.

Signature

def sliding(n: Int, step: Int = 1): Repr[immutable.Seq[Out]]

Provide a sliding window over the incoming stream and pass the windows as groups of elements downstream.

Note: the last window might be smaller than the requested size due to end of stream.

emits 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