take
Pass n
incoming elements downstream and then complete
Signature
Description
Pass n
incoming elements downstream and then complete
Example
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