passive-subscriber-infinite-problem.js

class MyService {

  constructor() {
    this._producer = Rx.Observable.of(1)
      .publish();
  }

  private _producer: Rx.ConnectableObservable<number>;

  startItUp(): Rx.Observable<number> {
    this._producer.connect();
    return this._producer;
  }

  get passiveValues(): Rx.Observable<string> {
    return this._producer.mapTo("got value");
  }
}