abstract class RxQuery
Static methods to Rx-ify ObjectBox queries.
<init> |
Static methods to Rx-ify ObjectBox queries. RxQuery() |
flowableOneByOne |
The returned Flowable emits Query results one by one. Once all results have been processed, onComplete is called. Uses BackpressureStrategy.BUFFER. open static fun <T : Any!> flowableOneByOne(query: Query<T>!): Flowable<T>!
The returned Flowable emits Query results one by one. Once all results have been processed, onComplete is called. Uses given BackpressureStrategy. open static fun <T : Any!> flowableOneByOne(query: Query<T>!, strategy: BackpressureStrategy!): Flowable<T>! |
observable |
The returned Observable emits Query results as Lists. Never completes, so you will get updates when underlying data changes (see open static fun <T : Any!> observable(query: Query<T>!): Observable<MutableList<T>!>! |
single |
The returned Single emits one Query result as a List. open static fun <T : Any!> single(query: Query<T>!): Single<MutableList<T>!>! |