A dataflow processing library