Summary: Fields | Methods | Inherited Methods

RxRoom

Kotlin |Java

public final class RxRoom
extends Object

java.lang.Object
↳	androidx.room.rxjava3.RxRoom

Helper class to add RxJava3 support to Room.

Summary

Fields
`public static final Object`	`NOTHING` Data dispatched by the publisher created by `createFlowable(RoomDatabase, String)`.

Public methods
`static Flowable<Object>`	`createFlowable(RoomDatabase database, String... tableNames)` Creates a `Flowable` that emits at least once and also re-emits whenever one of the observed tables is updated.
`static Observable<Object>`	`createObservable(RoomDatabase database, String... tableNames)` Creates a `Observable` that emits at least once and also re-emits whenever one of the observed tables is updated.

From class


        
          java.lang.Object

public static final Object NOTHING

Data dispatched by the publisher created by createFlowable(RoomDatabase, String).

public static Flowable<Object> createFlowable (RoomDatabase database, 
                String... tableNames)

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
`tableNames`	`String`: The list of table names that should be observed

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

public static Observable<Object> createObservable (RoomDatabase database, 
                String... tableNames)

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
`tableNames`	`String`: The list of table names that should be observed

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