A stream processing API for Go (alpha) - View it on GitHub