@asyncrs What's the equivalent of libstd's mpsc::Receiver::recv_timeout(x)?
`receiver.timeout(x).next()` something is the closest I got, but the docs on Stream::timeout is not clear if it's per item or if the entire stream becomes invalid.
-
-
I was thinking about that. But I was afraid dropping the recv() Future could lead to missed/dropped items. But if you say this is safe, I'll go with that

-
Because futures are "pull", not "push" it means that when you drop a receiver you simply stop taking items out of the queue. They don't go anywhere, hehe. This means in this case it's perfectly fine to just drop, and let another receiver take over at another time (:
- 3 more replies
New conversation -
Loading seems to be taking a while.
Twitter may be over capacity or experiencing a momentary hiccup. Try again or visit Twitter Status for more information.