takeWithin
Pass elements downstream within a timeout and then complete.
Timer driven operators
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.