如何从 RxJava Flowable 更新 JavaFX 进度条？

Question

我有以下反应代码：

//JavaFX ProgressBar
ProgressBar progressBar = new ProgressBar(0);

Flowable
        .fromIterable(itemList)
        .parallel()
        .runOn(Schedulers.io())
        .map(item -> {
            Thread.sleep(1000); //imitate expensive computation
            return item.getCode();
         })
         .sequential()
         .observeOn(JavaFxScheduler.platform())
         .subscribe(result -> {
             System.out.println(result);
          });

我想在 flowable 的每次迭代中更新 ProgressBar。

我想到了这样的事情：

int i= 0; //increment on every iteration
int total = itemList.size(); //total number if items in List
progressBar.setProgress((float)(i / total));

但是，我不知道如何在每次迭代结束时递增变量 i。

Answer 1

只需在订阅中递增 i

AtomicInteger i = new AtomicInteger(0);
Flowable
    .fromIterable(itemList)
    .parallel()
    .runOn(Schedulers.io())
    .map(item -> {
        Thread.sleep(1000); //imitate expensive computation
        return item.getCode();
     })
     .sequential()
     .observeOn(JavaFxScheduler.platform())
     .subscribe(result -> {
         i.increment();
         progressBar.setProgress((float)(i.get()/itemList.size))
         System.out.println(result);
      });

如何从 RxJava Flowable 更新 JavaFX 进度条？

How can I update a JavaFX progress bar from RxJava Flowable?

java

rx-java2