RxRoom

Added in 2.0.0

Kotlin |Java

public class RxRoom

Summary

Public fields
`static final @NonNull Object`	`NOTHING` Data dispatched by the publisher created by `createFlowable`.

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

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

public static final @NonNull Object NOTHING

Data dispatched by the publisher created by createFlowable.

Added in 2.0.0

Deprecated in 2.0.0

public RxRoom()

Added in 2.7.0

public static final @NonNull Flowable<@NonNull Object> createFlowable(
    @NonNull RoomDatabase database,
    @NonNull 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
`@NonNull RoomDatabase database`	The database instance
`@NonNull String... tableNames`	The list of table names that should be observed

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

Added in 2.7.0

public static final @NonNull Observable<@NonNull Object> createObservable(
    @NonNull RoomDatabase database,
    @NonNull 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
`@NonNull RoomDatabase database`	The database instance
`@NonNull String... tableNames`	The list of table names that should be observed

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