passive-subscriber-infinite-solution.js

class MyService3 {

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

  private _producer: Rx.ConnectableObservable<number>;

  startItUp(): Rx.Observable<number> {
    return Rx.Observable.create(obs => {
      const subs = this._producer.subscribe(obs);
      this._producer.connect();
      return subs;
    });
  }

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