a battery-included library for dataflow protocols - View it on GitHub