RxRoom

Added in 2.0.0

Kotlin |Java

Summary

Public companion functions
`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.	android
`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.	android

Public companion properties
`Any`	`NOTHING` Data dispatched by the publisher created by `createFlowable`.	android

Public constructors
`RxRoom()` This function is deprecated. This type should not be instantiated as it contains only utility functions.	android

android

Added in 2.7.2

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

android

Added in 2.7.2

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

android

val NOTHING: Any

Data dispatched by the publisher created by createFlowable.

android

Added in 2.0.0

Deprecated in 2.0.0

RxRoom()