は、機能を購読

Question

注意を実行していない：私は、私は5秒間画面にアイドルクリック回数を決定しようとしていますここrxjs（2.5.3）で

をtypescriptですを使用しています

var noClickStream = Rx.Observable.fromEvent<MouseEvent>($window.document, 'click') 
       .bufferWithTime(5000) 
       .filter(eventBundle => { 
        return eventBundle.length === 0; 
       }); 

これはこれは、コードの罰金を実行する機能を購読

var noClickStreamSubscriber = noClickStream.subscribeOnNext(() => {         
       this.showLogoutWarning = true; 
}); 

です。クリックが5秒間ないと、加入者が呼び出されます。

実際には、警告画面が表示されているときにsubscribe関数でnoClickStreamを一時停止して再開できるようにしたいと考えています。このために、最初のクリックストリームにpausable（）を追加しました。今noClickStreamSubscriber機能がなくても、クリック活動の5秒後に呼び出されることは決してありません

var noClickStream = Rx.Observable.fromEvent<MouseEvent>($window.document, 'click') 
      .bufferWithTime(5000) 
      .filter(eventBundle => { 
       return eventBundle.length === 0; 
      }) 
      .pausable(); 

。 fromEventは一時停止可能な機能をサポートしていませんか？

Answer 1

observableがpausableとして宣言されたときにsubscribe関数が実行されないのは、イベントストリームが一時停止状態で開始するためです。ストリームを機能させるには、subscribe関数が定義された後にnoClickStream.resume（）を呼び出さなければなりません。 Rx.Observable.fromEvent 変更

var noClickStream = Rx.Observable.fromEvent<MouseEvent>($window.document, 'click') 
      .bufferWithTime(5000) 
      .filter(eventBundle => { 
       return eventBundle.length === 0; 
      }) 
      .pausable(); 

var noClickStreamSubscriber = noClickStream.subscribeOnNext(() => {         
       this.showLogoutWarning = true; 
}); 

noClickStream.resume(); // This has to be invoked