A simple Go stream processing library