autoPublish

autoPublish-1.js

Rx.Observable.prototype.autoPublish = function () {
  var source = this.publish(),
      subscribers = 0,
      connection = null,
      dispose = function () {
        if (--subscribers === 0) { connection.dispose(); }
      };

  return Rx.Observable.createWithDisposable(function (o) {
    if (++subscribers === 1) { connection = source.connect(); }
    return new Rx.CompositeDisposable(source.subscribe(o), Rx.Disposable.create(dispose));
  });
};

autoPublish-2.js

Rx.Observable.prototype.autoPublish = function () {
  return this.publish().refCount();
};