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);

});