A simple scala library for flow-style processing