Concurrent processing pipelines in Go. - View it on GitHub