Rxjava 在从数据库中检索然后更新项目时创建一个循环

Question

我对 rxjava 有一个挑战，有一个 observable 可以从数据库中检索一个项目。我订阅了这个 observable 并且在从数据库中成功检索到一个项目后，我更新了那个项目。问题是在更新项目后，我的 observable 立即开始发出项目并再次调用更新方法，因此创建了一个循环。示例代码mOrderRepository.getOrder(orderId) .subscribeOn(mSchedulerProvider.io()) .observeOn(mSchedulerProvider.ui()) .subscribe((Order order) -> { // i calculate amount due after payment then update this order    order.setAmountDue(amountDue);    mOrderRepository.updateOrder(order);});