RxJS Observable로 조건이 충족 될 때까지 어떻게 ajax 요청을 반복합니까?

Question

응답이 RxJS를 사용하여 데이터를 가질 때까지 요청을 반복하려고하는데,이 시점에서 성공 (또는 실패) 처리기를 호출하고 싶지만 RxJS가 문제가 있습니다.

// ... redux-observable action observable 
.mergeMap(() => 
    fetchData() 
    .repeatWhen(response => 
     response.takeWhile(({ data }) => !data.length) 
     .of(response) 
    ) 
) 
.map(successFunction) 
.catch(failureFunction); 

면책 조항 : 여기 내 현재의 접근 방식이다 내가 RxJS 아주 새로운 해요 .... 당신이 아약스 결과를 억제하고 당신이 원하는 응답을 얻을 때까지 재 시도 할 같은

Answer 1

그것은 소리. 그래서처럼 할 거라고 : 먼저 우리는 데이터가 비어 있는지 확인하고 경우 오류가 발생하므로

// observable that will re-fetch each time it is subscribed 
const request = Observable.defer(() => fetchData()); 

// each time request produces its value, check the value 
// and if it is not what you want, return the request 
// observable, else return an observable with the response 
// use switchMap() to then subscribe to the returned 
// observable. 
const requestWithRetry = request.switchMap(r => 
    r.data.length ? Observable.of(r) : requestWithRetry); 

Answer 2

빈 데이터가 오류가 아닙니다. 이면 retryWhen을 사용하여이 오류를 테스트하고 오류가 발생하는 한 다시 시도 할 수 있습니다.

.mergeMap(() => 
    fetchData() 
    .map(data => { 
     if (!data.length) { 
      throw 'no data'; 
     } 
     return data; 
    }) 
    .retryWhen(errors => errors.takeWhile(error => error === 'no data')) 
) 
.map(successFunction) 
.catch(failureFunction); 

Answer 3

간격으로 요청을 반복하고, 결과를 필터링하고, 한 번 방출하는 것이 더 간단합니다.

Observable.timer(0, 500) 
    .flatMap(() => fetchData()) 
    .filter(r => r.data && r.data.length) 
    .take(1) 
    .timeout(10000) 

http://jsbin.com/cafericore/1/edit?js,console