RxJava only works with Queries?

[wengelef]

Is it not possible (out of the box) to use RxJava for insert/update?
Like return a Flowable<Long> or Flowable<Any> instead.

[mynote]

Since you use LiveData to listen for changes, you may use RxJava to listen for changed by observing Select * ...

The return value of update/delete are the row/inserted id which isnt used to observe for changes. If you really want to get this value in a different Thread use Flowable.fromCallable() Flowable.create() or Flowable.just().

I think this may be the reason for that.

[florina-muntenescu]

There is already a bug raised for this on the official bug tracker, here.

[birender-s]

i am also looking forward for this feature availability

[XtreeIvI]

1+

[florina-muntenescu]

RxJava is supported for insert/update/delete since Room 2.1.0-alpha01

[proninyaroslav]

@florina-muntenescu What about LiveData support?

[involve-it]

RxJava is supported for insert/update/delete since Room 2.1.0-alpha01

Could you please give us a hint on how to use it with room's insert/update/delete?

[proninyaroslav]

@involve-it
For example:

@Insert
Single<List<Long>> add(Foo... f); /* Id of added rows */

@Delete
Single<Integer> delete(Foo... f); /* Num of deleted rows */

@Update
Single<Integer> update(Foo... f); /* Num of updated rows */

And how to observe it:

Disposable d = db.fooDao().add(new Foo("bar"))
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(ids -> /* Do stuff */);
disposables.add(d);

[involve-it]

@involve-it
For example:

@Insert
Single<List<Long>> add(Foo... f); /* Id of added rows */

@Delete
Single<Integer> delete(Foo... f); /* Num of deleted rows */

@Update
Single<Integer> update(Foo... f); /* Num of updated rows */

And how to observe it:

Disposable d = db.fooDao().add(new Foo("bar"))
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(ids -> /* Do stuff */);
disposables.add(d);

Awesome, thanks!