A data cruncher library written with RX.  All async operations are done with RX.