Content and code samples on this page are subject to the licenses described in the Content License. Java and OpenJDK are trademarks or registered trademarks of Oracle and/or its affiliates.
Last updated 2025-02-10 UTC.
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Missing the information I need","missingTheInformationINeed","thumb-down"],["Too complicated / too many steps","tooComplicatedTooManySteps","thumb-down"],["Out of date","outOfDate","thumb-down"],["Samples / code issue","samplesCodeIssue","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2025-02-10 UTC."],[],[],null,["# RxRoom\n\nadded in [version 1.1.0](/topic/libraries/support-library/revisions) \nbelongs to Maven artifact android.arch.persistence.room:rxjava2:1.1.0-beta2 \nSummary: [Fields](#lfields) \\| [Ctors](#pubctors) \\| [Methods](#pubmethods) \\| [Inherited Methods](#inhmethods) \n\nRxRoom\n======\n\n| The `android.arch` Architecture Components packages are no longer maintained. They have been superseded by the corresponding [androidx.\\*](/jetpack/androidx/migrate) packages. See [androidx.room.RxRoom](/reference/androidx/room/RxRoom) instead.\n\n\n`\npublic\n\n\nclass\nRxRoom\n`\n\n\n`\n\nextends Object\n\n\n`\n\n`\n\n\n`\n\n|---|--------------------------------------|\n| java.lang.Object ||\n| ↳ | android.arch.persistence.room.RxRoom |\n\n\u003cbr /\u003e\n\n*** ** * ** ***\n\nHelper class to add RxJava2 support to Room.\n\nSummary\n-------\n\n| ### Fields ||\n|-------------------------------|-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|\n| ` public static final Object` | [NOTHING](/reference/android/arch/persistence/room/RxRoom#NOTHING) Data dispatched by the publisher created by [createFlowable(RoomDatabase, String)](/reference/android/arch/persistence/room/RxRoom#createFlowable(android.arch.persistence.room.RoomDatabase, java.lang.String...)). |\n\n| ### Public constructors ||\n|----------------------------------------------------------------------------|---|\n| ` `[RxRoom](/reference/android/arch/persistence/room/RxRoom#RxRoom())`() ` |\n\n| ### Public methods ||\n|----------------------------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|\n| ` static Flowable\u003cObject\u003e` | ` `[createFlowable](/reference/android/arch/persistence/room/RxRoom#createFlowable(android.arch.persistence.room.RoomDatabase, java.lang.String...))`(`[RoomDatabase](/reference/android/arch/persistence/room/RoomDatabase)` database, String... tableNames) ` Creates a [Flowable](/reference/io/reactivex/Flowable) that emits at least once and also re-emits whenever one of the observed tables is updated. |\n\n| ### Inherited methods |\n|-----------------------|---|\n| From class ` java.lang.Object ` |-------------------|-------------------------------| | ` Object` | ` clone() ` | | ` boolean` | ` equals(Object arg0) ` | | ` void` | ` finalize() ` | | ` final Class\u003c?\u003e` | ` 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() ` | ||\n\nFields\n------\n\n### NOTHING\n\nadded in [version 1.1.0](/topic/libraries/support-library/revisions) \n\n```\nObject NOTHING\n```\n\nData dispatched by the publisher created by [createFlowable(RoomDatabase, String)](/reference/android/arch/persistence/room/RxRoom#createFlowable(android.arch.persistence.room.RoomDatabase, java.lang.String...)).\n\n\u003cbr /\u003e\n\nPublic constructors\n-------------------\n\n### RxRoom\n\nadded in [version 1.1.0](/topic/libraries/support-library/revisions) \n\n```\nRxRoom ()\n```\n\n\u003cbr /\u003e\n\n\u003cbr /\u003e\n\nPublic methods\n--------------\n\n### createFlowable\n\nadded in [version 1.1.0](/topic/libraries/support-library/revisions) \n\n```\nFlowable\u003cObject\u003e createFlowable (RoomDatabase database, \n String... tableNames)\n```\n\nCreates a [Flowable](/reference/io/reactivex/Flowable) that emits at least once and also re-emits whenever one of the\nobserved tables is updated.\n\n\nYou can easily chain a database operation to downstream of this [Flowable](/reference/io/reactivex/Flowable) to ensure\nthat it re-runs when database is modified.\n\n\nSince database invalidation is batched, multiple changes in the database may results in just\n1 emission.\n\n\u003cbr /\u003e\n\n| Parameters ||\n|--------------|------------------------------------------------------------------|\n| `database` | `RoomDatabase`: The database instance \u003cbr /\u003e |\n| `tableNames` | `String`: The list of table names that should be observed \u003cbr /\u003e |\n\n| Returns ||\n|--------------------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|\n| `Flowable\u003cObject\u003e` | A [Flowable](/reference/io/reactivex/Flowable) which emits [NOTHING](/reference/android/arch/persistence/room/RxRoom#NOTHING) when one of the observed tables is modified (also once when the invalidation tracker connection is established). \u003cbr /\u003e |\n\n-\n\n Annotations\n -----------\n\n - [ColumnInfo](/reference/android/arch/persistence/room/ColumnInfo)\n - [ColumnInfo.Collate](/reference/android/arch/persistence/room/ColumnInfo.Collate)\n - [ColumnInfo.SQLiteTypeAffinity](/reference/android/arch/persistence/room/ColumnInfo.SQLiteTypeAffinity)\n - [Dao](/reference/android/arch/persistence/room/Dao)\n - [Database](/reference/android/arch/persistence/room/Database)\n - [Delete](/reference/android/arch/persistence/room/Delete)\n - [Embedded](/reference/android/arch/persistence/room/Embedded)\n - [Entity](/reference/android/arch/persistence/room/Entity)\n - [ForeignKey](/reference/android/arch/persistence/room/ForeignKey)\n - [ForeignKey.Action](/reference/android/arch/persistence/room/ForeignKey.Action)\n - [Ignore](/reference/android/arch/persistence/room/Ignore)\n - [Index](/reference/android/arch/persistence/room)\n - [Insert](/reference/android/arch/persistence/room/Insert)\n - [OnConflictStrategy](/reference/android/arch/persistence/room/OnConflictStrategy)\n - [PrimaryKey](/reference/android/arch/persistence/room/PrimaryKey)\n - [Query](/reference/android/arch/persistence/room/Query)\n - [RawQuery](/reference/android/arch/persistence/room/RawQuery)\n - [Relation](/reference/android/arch/persistence/room/Relation)\n - [SkipQueryVerification](/reference/android/arch/persistence/room/SkipQueryVerification)\n - [Transaction](/reference/android/arch/persistence/room/Transaction)\n - [TypeConverter](/reference/android/arch/persistence/room/TypeConverter)\n - [TypeConverters](/reference/android/arch/persistence/room/TypeConverters)\n - [Update](/reference/android/arch/persistence/room/Update)\n-\n\n Classes\n -------\n\n - [DatabaseConfiguration](/reference/android/arch/persistence/room/DatabaseConfiguration)\n - [InvalidationTracker](/reference/android/arch/persistence/room/InvalidationTracker)\n - [InvalidationTracker.Observer](/reference/android/arch/persistence/room/InvalidationTracker.Observer)\n - [Room](/reference/android/arch/persistence/room/Room)\n - [RoomDatabase](/reference/android/arch/persistence/room/RoomDatabase)\n - [RoomDatabase.Builder](/reference/android/arch/persistence/room/RoomDatabase.Builder)\n - [RoomDatabase.Callback](/reference/android/arch/persistence/room/RoomDatabase.Callback)\n - [RoomDatabase.MigrationContainer](/reference/android/arch/persistence/room/RoomDatabase.MigrationContainer)\n - [RoomWarnings](/reference/android/arch/persistence/room/RoomWarnings)\n - [RxRoom](/reference/android/arch/persistence/room/RxRoom)\n-\n\n Enums\n -----\n\n - [RoomDatabase.JournalMode](/reference/android/arch/persistence/room/RoomDatabase.JournalMode)\n-\n\n Exceptions\n ----------\n\n - [EmptyResultSetException](/reference/android/arch/persistence/room/EmptyResultSetException)"]]