I did that, using Go and its channels feature. Not much code and works like a charm.