如何使用Rxjava执行房间交易

Question

我如何在2个不同的DAO之间使用rxjava做一个房间事务？

我有这样的代码，我想用Rxjava来使用，但我需要它返回某种可观察的东西。

 @Transaction
fun insertStoreWithPictures(store: Store, pictures: List<StorePicture>) {

    insertStore(store)
    insertPictures(pictures)

}

商店DAO

@Dao
abstract public class store {

@Insert
Single<Long> insert(store  entity);
}

商店图片DAO

@Dao
abstract public class storePicture {

    @Insert
    Completable insert(storePicture... entity);
}

Answer 1

我想你可以使用 zip 或 combine 的经营者 RxJava. 它将从迭代器observable源创建一个observable。

Answer 2

你可以遵循的最好的例子来实现同样的目的--。https:/blog.mindorks.comunderstanding-rxjava-zip-operator-with-example。