RXJavaSupport

RXJava support in DBFlow is an incubating feature and likely to change over time. We support both RX1 and RX2 and have made the extensions + DBFlow compatibility almost identical - save for the changes and where it makes sense in each version.
Currently it supports
1.Any ModelQueriable can be wrapped in a Single, Maybe, or Flowable (to continuously observe changes).
2.Single + List model save(), insert(), update(), and delete().
3.Streaming a set of results from a query
4.Observing on table changes for specific ModelQueriable and providing ability to query from that set repeatedly as needed.
Getting Started
Add the separate packages to your project:
dependencies {
​
  // RXJava3
  compile "com.github.agrosner.dbflow:reactive-streams:${dbflow_version}"
​
}
Wrapper Language
We can convert wrapper queries into different kinds of RX operations.
For a single query:
Using vanilla transactions:
(select
  from MyTable::class)
  .async(db) { d -> queryList(d) }
  .execute { _, r ->}
Using RX:
(select
  from MyTable::class)
  .async(db) { d -> queryList(d) }
  .asSingle()
  .subscribeBy { list ->
    // use list
  }
Observable Queries
We can easily observe a query for any table changes (once per transaction) while it is active and recompute via:
(select
  from MyTable::class)
  .asFlowable { db -> queryList(db) }
  .subscribeBy { list ->
    // use list
  }
This works across joins as well.
Model operations
Operations are as easy as:
Person(5, "Andrew Grosner")
  .rxInsert(db) // rxSave, rxUpdate, etc.
  .subscribeBy { rowId ->
​
  }
Query Stream
We can use RX to stream the result set, one at a time from the ModelQueriable using the method queryStreamResults():
(select from TestModel::class)
   .queryStreamResults(db)
   .subscribeBy { model ->
​
   }

Observability

ContentProviderGeneration

Last modified 2yr ago