조건부 RxJS 스트림

Question

resource1$ = hash1$.map((renew: boolean) => renew ? http1$ : Observable.empty()); 
resource2$ = hash2$.map((renew: boolean) => renew ? http2$ : Observable.empty()); 

sync$ = Observable.forkJoin(resource1$, resource2$); 

sync$.subscribe(() => console.log('Sync done!), (err) => console.log('Sync failed!')); 

안녕하세요, 안녕하세요, 응용 프로그램을 시작할 때 API에서 동기화 할 리소스가 여러 개 있습니다. 나는 그것들을 병렬로 동기화하고 HEAD 요청을 사용하여 X-HASH 헤더를 이전에 저장된 것과 비교하는 데 필요한지 확인해야한다.

그래서 hash1 $는 HEAD 요청을 수행하고 해시를 비교하여 true 또는 false를 반환합니다.

resource1 $이 (가) Observable.empty를 반환하면 모든 $ 스트림을 취소합니다. 이유를 모르겠다.

Answer 1

forkJoin은 모든 소스 관찰 도구가 하나 이상의 항목을 방출하고 완료해야합니다. Observable.empty()을 사용하는 경우 complete 알림 만 전송되므로 forkJoin이 전송되지 않습니다. 당신은 예를 들어 할 수있는

:

resource1$ = hash1$.map((renew: boolean) => renew ? http1$ : Observable.of(false)); 
resource2$ = hash2$.map((renew: boolean) => renew ? http2$ : Observable.of(false)); 

sync$ = Observable.forkJoin(resource1$, resource2$) 
    .filter(results => results[0] && results[1]); // Or whatever condition you want