NSQ protocol for Node.js implemented as a through stream - View it on GitHub