takeWithin

Pass elements downstream within a timeout and then complete.

Timer driven stages

Signature

def takeWithin(d: FiniteDuration): Repr[Out]

Description

Pass elements downstream within a timeout and then complete.

emits when an upstream element arrives

backpressures downstream backpressures

completes upstream completes or timer fires

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.