sliding

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

Simple operators

Signature

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

Description

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.

Reactive Streams semantics

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

Found an error in this documentation? The source code for this page can be found here. Please feel free to edit and contribute a pull request.