我想"insert record to room database"-> "Api call "-> "Update local record"

Question

我是 rxjava android 的新手。我想在本地房间数据库中插入记录。我设置了自动生成 true，以便它会为我生成 id。然后我想进行 api 调用以将该记录发送到服务器。在 api 调用中取得成功后，我想使用从服务器获取的 serverId 更新本地数据库中以前添加的记录。我知道我可以使用 rxjava 平面图实现这个序列，但我不知道怎么做。

这是我返回 id 的插入方法

@Insert
Single<Long> insertMessage(ChatMessage chatMessage);

这是我的 API 调用

@POST(ApiConstants.API_CHAT_SEND_MESSAGE)
Single<SendMessageResponse> sendChatMessage(@Body PostChatMessage postChatMessage);

这是我的更新方法

@Query("UPDATE message SET id = :id WHERE localId = :idToUpdate")
Single<Integer> updateMessage(String id, int idToUpdate);

任何帮助将不胜感激

Answer 1

我以这种方式为我感到疲倦，它工作正常，给了我预期的结果

messageDao.insertMessage(chatMessage)
.subscribeOn(Schedulers.io())
.flatMap(id -> {
return ApiServiceClient.getApiServiceNew().sendChatMessage(postChatMessage).flatMap(sendMessageResponse -> {
messageDao.updateMessage(sendMessageResponse.getData().getId(), id);
return Single.just(id);
});
})
.observeOn(AndroidSchedulers.mainThread())
.subscribeWith(new SingleObserver<Long>() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onSuccess(Long aLong) {
Log.d(TAG,"Record updated"+aLong);
}
@Override
public void onError(Throwable e) {
Log.d(TAG,"Record Failed"+e.getMessage());
}
});