Async flowing

Updated river flowing to be asynchronous using TPL dataflow blocks.