A stream processing API for Go (now with generic type support) - View it on GitHub