NSQ protocol for Node.js implemented as a through stream