RxJava aus der Liste mit Asynchron Warten auf Rückruf

Question

List<String> listExample = Arrays.asList("one", "two", "three"); 

Denken Sie an i Liste der Zeichenfolge haben, und mit RxJava (Observable.fromArray)

Observable.fromArray(ids.toArray(new String[ids.size()])).subscribe(new Consumer<String>() { 
    @Override 
    public void accept(@NonNull String s) throws Exception { 

    } 
}); 

denken hier jede Saite einen Async Rückruf hat hier einmal i erhalten, dass Callback sollte es zum nächsten String bewegen. Ist es möglich, rxjava zu verwenden?

Dies ist der Code, den ich derzeit habe, es wartet nicht bis zum Rückruf richtig !.

for (String id : ids) { 
    getMessage(id, new urlGenCallback() { 
     @Override 
     public void urlAndToken(String url, String token, String idx) { 

     } 
    }); 
} 

Danke @Geoffrey Marizy

Antwort: Check Below für weitere Informationen über ConcatMap Visit Here

Answer 1

Sie sind mit dem concatMap Betreiber suchen. Eine vollständige Artikel zu diesem Thema: https://fernandocejas.com/2015/01/11/rxjava-observable-tranformation-concatmap-vs-flatmap/

Ihre Anfrage als beobachtbare Wickeln Sie es dann als Parameter an concatMap passieren:

Observable.fromArray(ids.toArray(new String[ids.size()])).concatMap(/* your request returning an Observable */) 

Answer 2

Observable.fromArray(ids.toArray(new String[ids.size()])) 
     .concatMap(s -> { 
      return Observable.create(new ObservableOnSubscribe<String>() { 
       @Override 
       public void subscribe(@NonNull ObservableEmitter<String> e) throws Exception { 
        getMessage(s, new urlGenCallback() { 
         @Override 
         public void urlAndToken(String url, String token, String id) { 
          e.onNext("......"); 
          e.onComplete(); 
         } 
        }); 
       } 
      }); 
     }).subscribe(new Consumer<String>() { 
    @Override 
    public void accept(@NonNull String s) throws Exception { 
     //All other code goes here 
    } 
});