Implementing socket.io-stream