###前提・実現したいこと
Angular(5系)でSPAを作成しています。
ここで、ページネーションするAPIで、RxJSを用いて1ページ目から最後まで順番に取得したいのですが、うまく行かず困っています。
言い換えると「Observableの非同期処理を直列で実行(回数は受け取るデータによって判断)」
という感じでしょうか。。
調べてみるとconcatMap
が見つかるのですが、
どのサンプルも回数が分かってる(決まってる)ようなものしかなく、
今回のように、受け取ったデータを見て判断するものが見つかりませんでした。
鍵になるRxJSのオペレータ、メソッド、
または参考になりそうな記事などお教えいただけないでしょうか。
(もちろん下記のコードを埋めていただいても大歓迎です。)
よろしくお願いいたします。
ソースコード
TypeScript
1interface ResponseData { 2 data: Item[]; 3 current_page: number; 4 last_page: number; 5 // ...省略 6} 7 8class ApiService { 9 constructor(private http: HttpClient) {} 10 11 // ページを指定して、リクエストを投げる (これを順番に実行したい) 12 fetch(page: number): Observable<ResponseData> { 13 const params = { page: page + '' }; 14 return this.http.get<ResponseData>('api/items', { params }); 15 } 16 17 // 1ページ目から最後まで、順番にリクエストを投げる 18 fetchAll(): Observable<ResponseData[]> { 19 // ここを実装したい 20 } 21}