Rxjs observableが何らかの条件が満たされるまで待機する

Question

操作を再試行するための再試行ロジックがあります。 1回のリクエストでうまく動作します。複数の進行中の要求については、再試行する前に既存の再試行ロジックが完了するのを待っています。

handleError(errors: Observable<any>) { 

    const retryCountStart: number = 1; 

    // wait if there is any existing operation retrying 
    // once it is complete, continue here 

    return errors 
     .mergeScan<any, any>(
     (retryCount: any, err: any) => { 

      if (retryCount <= 5) { 
       return Observable.of(retryCount + 1); 
      } 

     },retryCountStart) 
     .delay(1000); 
} 

上記の方法で条件が満たされるまでに遅延を追加するにはどうすればよいですか？

Answer 1

あなたは約束を決意して、その目的のためにasync/awaitを使用することができます迅速な応答を

async handleError(errors: Observable<any>) { 

    const retryCountStart: number = 1; 

    // wait if there is any existing operation retrying 
    // ---------------------------------------------------------- 
    await new Promise(resolve => { 
     // declare some global variable to check in while loop 
     while(this.retrying){ 
      setTimeout(()=> { 
       // Just adding some delay 
       // (you can remove this setTimeout block if you want) 
      },50); 
     } 

     // when while-loop breaks, resolve the promise to continue 
     resolve(); 
    }); 
    // ---------------------------------------------------------- 

    // once it is complete, continue here 

    return errors 
     .mergeScan<any, any>(
     (retryCount: any, err: any) => { 

      if (retryCount <= 5) { 
       return Observable.of(retryCount + 1); 
      } 

     },retryCountStart) 
     .delay(1000); 
}