Как выполнить транзакцию комнаты с помощью Rxjava

Question

Как я могу выполнить транзакцию комнаты через 2 разных DAO с использованием rx java?

У меня есть этот код, который я хотел бы использовать с Rx java, но мне нужно, чтобы он возвращал какой-то наблюдаемый

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

    insertStore(store)
    insertPictures(pictures)

}

Магазин DAO

@Dao
abstract public class store {

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

МагазинPicture DAO

@Dao
abstract public class storePicture {

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

Answer 1

Лучший пример, которому вы можете следовать, чтобы добиться того же - https://blog.mindorks.com/understanding-rxjava-zip-operator-with-example

Answer 2

Я думаю, вы можете использовать zip или combine оператор RxJava. Это создало бы наблюдаемую из наблюдаемого источника итератора.