added in version 1.1.0
belongs to Maven artifact android.arch.persistence.room:rxjava2:1.1.0-beta2

Summary: Fields | Ctors | Methods | Inherited Methods

RxRoom

The android.arch Architecture Components packages are no longer maintained. They have been superseded by the corresponding androidx.* packages. See androidx.room.RxRoom instead.

public class RxRoom
extends Object

java.lang.Object
↳	android.arch.persistence.room.RxRoom

---

Helper class to add RxJava2 support to Room.

Summary

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

Public constructors
RxRoom()

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.

Inherited methods
From class java.lang.Object Object clone() boolean equals(Object arg0) void finalize() final Class<?> getClass() int hashCode() final void notify() final void notifyAll() String toString() final void wait(long arg0, int arg1) final void wait(long arg0) final void wait()

Fields

NOTHING

added in version 1.1.0

Object NOTHING

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

Public constructors

RxRoom

added in version 1.1.0

RxRoom ()

Public methods

createFlowable

added in version 1.1.0

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

• Annotations

  • ColumnInfo
  • ColumnInfo.Collate
  • ColumnInfo.SQLiteTypeAffinity
  • Dao
  • Database
  • Delete
  • Embedded
  • Entity
  • ForeignKey
  • ForeignKey.Action
  • Ignore
  • Index
  • Insert
  • OnConflictStrategy
  • PrimaryKey
  • Query
  • RawQuery
  • Relation
  • SkipQueryVerification
  • Transaction
  • TypeConverter
  • TypeConverters
  • Update

• Classes

  • DatabaseConfiguration
  • InvalidationTracker
  • InvalidationTracker.Observer
  • Room
  • RoomDatabase
  • RoomDatabase.Builder
  • RoomDatabase.Callback
  • RoomDatabase.MigrationContainer
  • RoomWarnings
  • RxRoom

• Enums

  • RoomDatabase.JournalMode

• Exceptions

  • EmptyResultSetException