take

Pass n incoming elements downstream and then complete

Simple operators

Signature

def take(n: Long): Repr[Out]

Description

Pass n incoming elements downstream and then complete

Reactive Streams semantics

emits while the specified number of elements to take has not yet been reached

backpressures when downstream backpressures

completes when the defined number of elements has been taken or 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.