Generic abstraction for building dataflow computations. - View it on GitHub