RxJS and Socket.io

gistfile1.js

var emit = Rx.Observable
          .fromNodeCallback(that.socket.emit,
                            null,
                            that.socket); // Socket.io needs the socket as the context to handle ack.
emit.subscribe(function() {
    // ...
});