Designing Reactive Coroutine Streams

Implement operators similar to reactive extensions to combine, filter, and transform asynchronous event streams.