androidx.room.rxjava3


Exceptions

EmptyResultSetException

Thrown by Room when the query in a io.reactivex.rxjava3.core.Single DAO method needs to return a result but the returned result from the database is empty.

Top-level functions summary

Flowable<Any>
createFlowable(database: RoomDatabase, vararg tableNames: String)

Creates a Flowable that emits at least once and also re-emits whenever one of the observed tables is updated.

Observable<Any>
createObservable(database: RoomDatabase, vararg tableNames: String)

Creates a Observable that emits at least once and also re-emits whenever one of the observed tables is updated.

Top-level properties summary

Any

Data dispatched by the publisher created by createFlowable.

Top-level functions

createFlowable

fun createFlowable(database: RoomDatabase, vararg tableNames: String): Flowable<Any>

Creates a Flowable that emits at least once and also re-emits whenever one of the observed tables is updated.

You can easily chain a database operation to downstream of this Flowable to ensure that it re-runs when database is modified.

Since database invalidation is batched, multiple changes in the database may results in just 1 emission.

Parameters
database: RoomDatabase

The database instance

vararg tableNames: String

The list of table names that should be observed

Returns
Flowable<Any>

A Flowable which emits NOTHING when one of the observed tables is modified (also once when the invalidation tracker connection is established).

createObservable

fun createObservable(database: RoomDatabase, vararg tableNames: String): Observable<Any>

Creates a Observable that emits at least once and also re-emits whenever one of the observed tables is updated.

You can easily chain a database operation to downstream of this Observable to ensure that it re-runs when database is modified.

Since database invalidation is batched, multiple changes in the database may results in just 1 emission.

Parameters
database: RoomDatabase

The database instance

vararg tableNames: String

The list of table names that should be observed

Returns
Observable<Any>

A Observable which emits NOTHING when one of the observed tables is modified (also once when the invalidation tracker connection is established).

Top-level properties

NOTHING

val NOTHINGAny

Data dispatched by the publisher created by createFlowable.