最初のリクエストが完了するまでアクションを無視するEpic

Question

同僚と私はAndroidアプリケーションにフローのようなフローを追加して、最初のコールが完了するまでアクションの受信を停止する叙事詩を作成する方法を理解できません。

私はskipUntil()を使うことができたと思っていましたが、skipUntil()の結果が残り、チェーンの残りの部分に渡されることはありませんでした。

以下は、私たちが達成しようとしていることを示す、大雑把なJSコードです。

const fetchUserEpic = action$ => 
    action$.ofType(FETCH_USER) 
    .skipUntil(/* first request completes */) 
    .mergeMap(action => 
     ajax.getJSON(`/api/users/${action.payload}`) 
     .map(response => fetchUserFulfilled(response)) 
     .takeUntil(action$.ofType(FETCH_USER_CANCELLED)) 
    ); 

それは、観察が進行中である場合は、すべての項目を無視して、私は、switchMap()のように動作しますが、一度に一つのリクエストを尊重skipMap()オペレータを必要とするほとんどのようなものです。

ありがとうございます。

Answer 1

として、あなたはそれは（あなたが以前のクエリを実行しながら、それが入力を落とし、通常ではありません結果が時代遅れであることを意味し、switchMapおよび/またはdebounceが通常好ましい）何が必要だ、take(1) + repeatが動作するはずかなり確信していると仮定すると、観察可能な行動は熱いです。

const fetchUserEpic = action$ => 
    action$.ofType(FETCH_USER) 
    .take(1) 
    .concatMap(action => 
     ajax.getJSON(`/api/users/${action.payload}`) 
     .map(response => fetchUserFulfilled(response)) 
     .takeUntil(action$.ofType(FETCH_USER_CANCELLED)) 
    ) 
    .repeat() 

ロジックをシミュレートするスニペットです。

// simulate action$.ofType(FETCH_USER) every second 
 
const obs1 = Rx.Observable.interval(1000).publish() 
 
obs1.connect() 
 

 
function getStuff(i) { 
 
    return Rx.Observable.timer(i*1000).mapTo(i) 
 
} 
 

 
obs1.take(1).concatMap(getStuff).repeat().subscribe(console.log)

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/5.0.2/Rx.js"></script>

Answer 2

あなたは空想何もする必要はありません、このため、オペレータがexhaustMapと呼ばれる、すでに存在しています。 exhaustMapは、concatMapに似ていますが、前の処理がまだ処理されている間に入ってきた要求は、静かに削除されます。

const fetchUserEpic = action$ => 
    action$.ofType(FETCH_USER) 
    .exhaustMap(action => 
     ajax.getJSON(`/api/users/${action.payload}`) 
     .map(response => fetchUserFulfilled(response)) 
     .takeUntil(action$.ofType(FETCH_USER_CANCELLED)) 
    );