Creating an Rx.js Observable from a STOMP over Websocket source (with error handling)

gistfile1.js

// see: https://github.com/jmesnil/stomp-websocket

var client = Stomp.client('ws://...');
client.debug = undefined;

var live = Rx.Observable.create(function (observer) {
  console.log('Connecting...')
  client.connect(username, password, function(frame) {
    console.log(frame.toString());
    observer.onNext(frame);
  }, function(error) {
    observer.onError(new Error(error));
  });
})
.flatMap(function() {
  return Rx.Observable.create(function (observer) {
    client.subscribe('/queue/some_queue', function(message) {
      observer.onNext(event);
      return function() {
        client.disconnect(function() {
          console.log('Disconnected.');
        });
      };
    }, function(error) {
      observer.onError(new Error(error));
    })
  })
})
.map(function(message) {
  ...
});