A high level NodeJS stream processing library - View it on GitHub