android - 使用RxJava将列表插入 session 室数据库

Question

我有一个要映射的项目列表，然后插入到“房间”表中:

房间

@Insert(onConflict = OnConflictStrategy.REPLACE)
fun insert(vararg projectLocal: ProjectLocal): Completable

FIRST 方法来保存数据:

Observable.fromIterable(remoteProjects)
            .map { project ->
                ...
                mProjectMapper.mapRemoteToLocal(project)
            }
            .observeOn(AndroidSchedulers.mainThread())
            .subscribeOn(Schedulers.io())
            .subscribe {
                mProjectRepository.saveProject(it)
            }

如您所见，我是 observing on -> main thread和 subscribing on -> io
用于存储数据的第二种方法:

remoteProjects.forEach { remote ->
                ...
                val project = mProjectMapper.mapRemoteToLocal(remote)
                mProjectRepository.saveProject(project)
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribeOn(Schedulers.io())
                    .subscribe()
            }

哪一个更有意义？是否有更好的方法使用RxJava将所有这些数据保存在Room数据库中？

Answer 1

我认为这就是@Mwasz的意思:

Observable.fromIterable(remoteProjects)
        .map { project ->
            mProjectMapper.mapRemoteToLocal(project)
        }
        .toList()
        .flatMapCompletable {
            mProjectRepository.saveProject(it)
                .subscribeOn(Schedulers.io())
        }
        .subscribe()

您也可以使用 reduce或 collect代替 toList，但 toList()是最简单的。