You could also just use Primus which exposes a Stream compatible wrapper by default for the client and server.
https://github.com/primus/primus
(Primus uses engine.io,sockjs,browserchannel,websockets internally so you're no longer locked into a specific framework)