limit

Limit number of element from upstream to given max number.

Simple operators

Signature

def limit(max: Long): Repr[Out] = limitWeighted(max)(_

Description

Limit number of element from upstream to given max number.

emits when upstream emits and the number of emitted elements has not reached max

backpressures when downstream backpressures

completes when upstream completes and the number of emitted elements has not reached max

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.