2 Commits

Author SHA1 Message Date
Jonathan Turner
d7b1480ad0
Another batch of removing async_stream (#1981) 2020-06-14 11:54:35 +12:00
Jason Gedge
2a54ee0c54 Introduce InterruptibleStream type.
An interruptible stream can query an `AtomicBool. If that bool is true,
the stream will no longer produce any values.

Also introducing the `Interruptible` trait, which extends any `Stream`
with the `interruptible` function, to simplify the construction and
allow chaining.
2020-03-29 17:03:01 -04:00