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