rxjs非同期サブジェクトで2回目の.next（）を起動するには？

Question

私は2つのボタンを持つコンポーネントを持っています。下の与えられたプランカのデモに従って最初のボタンをクリックすると、イベントが発生し、私のサービス関数はいくつかの値を持つ非同期のサブジェクトを放出します...ボタンをクリックすると、再び.nextイベントを呼び出そうとしていますが、何らかのエラーが発生しています...私はここでプルーカのデモを作っていますhttp://plnkr.co/edit/wpyV7o9JErdQMzGFZ4wp?p=preview ...私はそれをうまく動作しますが、

export class ErrorService{ 
    latestError:AsyncSubject<string> = new AsyncSubject(); 

    Save() { 
    this.latestError.next('form submitted'); 
    this.latestError.complete(); 
    } 

    Update(){ 
    this.latestError.next('form updated'); 
    this.latestError.complete(); 
    } 
} 

これは私のサービスクラスです。これは非同期サブジェクトの.nextイベントを呼び出す方法です。

this.service.latestError.subscribe(
err=> { 
    console.log('result = '+err); 
    this.result=err; 
}, 
err => { 
    console.log('err'); 
}, 
() => { 
    console.log('complete'); 
}); 

そして、これは私が非同期の件名を購読している方法です...クリックイベントが初めて正常に動作しますが、私はそれがerror.Somebodyは、このエラーを解決するために私を助けてくださいスロー別のボタンをクリックしたとき。.. 。私はどのように私の非同期サブジェクトを使用して2回目の.next（）を呼び出すことができます...ありがとう事前に

Answer 1

それはあなたがcompleteメソッドを呼び出すためです。データフローチェーンが終了し、イベントを受信できなくなります。

Answer 2

私は初めてのボタンをクリックした場合でも、私はそれがどんな値を放出されていない、完全なメソッドを呼び出してはいけない場合は、この

this.service.latestError.subscribe(
err=> { 
    this.service.latestError = new AsyncSubject(); // this set isStopped property to false again 
    console.log('result = '+err); 
    this.result=err; 
}, 
err => { 
    console.log('err'); 
}, 
() => { 
    console.log('complete'); 
});