Wie konvertiere ich dieses RxJava-Observable, um alle 200 ms Ergebnisse zu erhalten?

Question

Ich habe diese Observable:

Observable<String> concatenatedSets = 
      Observable.just("1/5/8", "1/9/11/58/16/", "9/15/56/49/21"); 

    concatenatedSets.flatMap(s -> Observable.from(s.split("/"))) 
      .map(s -> Integer.valueOf(s)) 
      .subscribeOn(Schedulers.computation()) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .subscribe(i -> tvCounter.setText(String.valueOf(i))); 

wie konvertiere ich es oder welche Bediener kann die Kette ich es so, dass onNext mit 200 ms zwischen Anrufe genannt wird?

ich bei dieser Frage SO suchen: Pause between call onNext in RxJava

aber Antworten dort beginnen mit einer Pause zu schaffen interval mit wie so

Observable.interval(100, TimeUnit.MILLISECONDS) 

Allerdings bin ich meine beobachtbaren auf eine andere Weise zu schaffen (mit just), also wie mische ich beide Funktionalitäten (just und interval) oder was mache ich, um eine Pause von 200 ms zwischen den Emissionen zu erreichen?

PS: gerade versucht delay - es aufgeschoben Gesamtausführung einmal um die Zeit, die ich zur Verfügung gestellt. zip könnte die Antwort sein, aber es ist sehr verwirrend, also wie zip ich meine beobachtbare und ein Intervall eins?

Answer 1

Observable<Integer> observable = Observable.just("1/5/8", "1/9/11/58/16/", "9/15/56/49/21") 
       .flatMap(s -> Observable.from(s.split("/"))) 
       .map(s -> Integer.valueOf(s)); 

Observable<Integer> zippedObservable = Observable.zip(
       observable, 
       Observable.interval(100, TimeUnit.MILLISECONDS), 
       (number, interval) -> number); 

zippedObservable 
     .subscribeOn(Schedulers.computation()) 
     .observeOn(AndroidSchedulers.mainThread()) 
     .subscribe(i -> tvCounter.setText(String.valueOf(i)));