android RxJava Observable.fromからサービスに投稿する

Question

私はいくつかの値を抽出し、アイテムごとにAPI呼び出しを行う必要がある項目のリストを持っています。すべての呼び出しが並行して行われている理由の問題があるので、私はthis_

Observable.from(myList) 
    .flatMap{ item -> 
     return serviceInteractor.uploadToServer(item) 
    } 
    .map { serverResponse -> 
     return serverResponse.getResponseCode 
    } 
    .toList() 
    .subscrible{ responseList -> 
    // do something with all the responses 
    } 

オクラホマのようなものを使っていることを行うために、私は知りません。 最初の応答を待ち、結果をマップし、Observable.from（）の次の項目に進み、最後にresponseMessagesの最終リストを返しますか？起こっていることは、すべてが同時に起こることです。これを確認するには、toListメソッドの前に遅延（1、TimeUnit.Seconds）を入れると、すべてが同時に発生し、最後のonNextだけが遅延します。

どうすればいいですか？ IDのリストを持っていて、1つずつサーバにアップロードし、それぞれが完了するのを待って、成功または失敗した場合は次へ進みます。

Answer 1

throughtより多くの情報を得ることができますはいあなたはConcatMap

を使用する必要があります

フラットマップはmerge operatorを使用し、concatMapはconcat opertorを使用します。

ここでこのanswer

で説明したように、この例に見てみることができますordered

ので、シーケンスがある。この

flatMap出力シーケンスのようになりますmerged
concatMap出力配列である

String arrData[] = {"0", "1", "2", "3", "4"}; 
Integer arrDelay[] = {1000, 6000, 4000, 9000, 2000}; 

Observable.from(arrData) 
      .concatMap(s -> Observable.from(arrData) 
         .delay(arrDelay[Integer.parseInt(s)],TimeUnit.MILLISECONDS)) 

      .map(integer -> integer) 
      .toList() 
      .doOnCompleted(() -> Log.v("log", "doOnCompleted")) 
      .subscribe(integer -> Log.v("log", "" + integer)); 

ここy OUは、私たちが、私はこの:)

Answer 2

flatMapは呼び出しをスタックします。 Observableのそれぞれに加入し、到着順に結果を送信します。結果はではなく、となります（documentation参照）。

あなたは結果が順序付けられていることを望んでいるならば、あなたはconcatMap演算子をご覧ください。（documentationを参照）

Observable.from(myList) 
    .concatMap{ item -> 
       return serviceInteractor.uploadToServer(item) 
     } 
    .map { serverResponse -> 
     return serverResponse.getResponseCode 
     } 
    .toList() 
    .subscrible{ responseList -> 
     // do something with all the responses 
    } 

あなたはthis blog post.