Rxjs、プロパティを設定するために待機して通知するのが最善の方法ですか？

Question

このプロパティに応じて別のサービスを実行するために、あるサービスで非同期的にプロパティを設定するのを待つ必要があります。

これは現在私がこれを解決するためにやっていることですが、Rxjsなどの方が良いアプローチがあるのだろうかと思います。この例では

私は他のサービスを「通知」するために、初期化すると、私はEventEmitterを使用しているプロパティ_isInitを待っている：あなたはこのようReplaySubjectを使用することができ

class OneService { 

    private _isInit 
    private _initStatus = new EventEmitter() 

    constructor() { 
     Promise.all([ 
      Promise1(), //async task 
      Promise2(), //async task 
     ]) 
     .then(res => { 
      ... //doing stuff 
      this.init() //stuff finished, OneService is initiated 
     }) 
    } 

    init() { 
     this._isInit = true 
     this._initStatus.emit(this._isInit) 
    } 

    isInit() { 
     return new Promise(resolve => { 
      if (this._isInit) 
       resolve() 
      else { 
       this._initStatus.subscribe(() => { 
        resolve() 
       }) 
      } 
     }) 
    } 
} 

class anotherService { 

    constructor(myService: OneService) { 
     this.myService.isInit().then(() => { 
      ... //doing stuff 
     }) 
    } 

} 

Answer 1

：たぶん

class OneService { 

    public valueStream = new ReplaySubject(); 

    constructor() { 
     Promise.all([ 
      Promise1(), //async task 
      Promise2(), //async task 
     ]) 
     .then(res => { 
      ... //doing stuff 
      this.valueStream.next(value) 
     }) 
    } 

} 

class anotherService { 

    constructor(myService: OneService) { 
     this.myService.valueStream.subscribe((value) => { 
      ... //doing stuff 
     }) 
    } 

}