RxJava Flowable<List<T>> 对每个项目进行操作，然后对结果列表进行操作

Question

我有一个Flowable<List<Item>> 我想要：

1. 对每个项目进行操作
2. 之后，我想对整个结果列表进行操作。

这现在不起作用，因为它看起来像是进入了一个无限循环::

        return list.concatMap(list ->
                    Observable.fromIterable(list)
                            .map(item -> {
                                item.setValue(value);
                                return item;
                            }).toList().toFlowable()
                            .flatMap(updatedList -> mLocalDataSource.update(updatedList)))
                    .subscribeOn(Schedulers.io())
                    .observeOn(AndroidSchedulers.mainThread());

Answer 1

我认为在flatMap()/concatMap() 中进行这项工作没有任何优势。我想说的是，如果Item 是不可变的，它会更干净。

list.concatMap(items -> {
  for(Item item : items)
    item.setValue(value);
  return mLocalDataSource.update(items)
});