objectbox-rxjava3 / io.objectbox.rx3 / io.objectbox.query.Query

Extensions for io.objectbox.query.Query

flowableOneByOne

Shortcut for RxQuery.flowableOneByOne(query, strategy).

fun <T> Query<T>.flowableOneByOne(strategy: BackpressureStrategy = BackpressureStrategy.BUFFER): Flowable<T>

observable

Shortcut for RxQuery.observable(query).

fun <T> Query<T>.observable(): Observable<MutableList<T>>

single

Shortcut for RxQuery.single(query).

fun <T> Query<T>.single(): Single<MutableList<T>>