The reactive dataflow framework from my PhD thesis - View it on GitHub