使用RxJava获取插入id（房间）

Question

我可以使用RxJava添加一行，如下所示，

Completable.fromAction(() -> db.userDao().insert(user)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new CompletableObserver() {
            @Override
            public void onSubscribe(Disposable d) {

            }

            @Override
            public void onComplete() {

            }

            @Override
            public void onError(Throwable e) {

            }
        });

道：

@Insert(onConflict = OnConflictStrategy.REPLACE)
    long insert(User user);

DB操作后如何获取行id？

Answer 1

如果要在Room中使用RxJava，可以更改插入函数以返回RxJava单次包装的长度，如：

@Insert
Single<Long> insert(User user);

这样，您只需订阅这张单张，只要使用以下内容，您就可以获得id：

db.userDao().insert(user)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new SingleObserver<Long>() {
            @Override
            public void onSubscribe(Disposable d) {
            }
            @Override
            public void onSuccess(Long aLong) {
                // aLong is the id
            }
            @Override
            public void onError(Throwable e) {
            }
        });