Reactive dataflow processing. - View it on GitHub