Removed Dataflow class and put #dataflow method directly on Concurrent module.