This is an implementation of the problem described in Comparing Core Async and Rx by Example

See the source code