objectbox-rxjava3

alltypes

io.objectbox.query.Query

fun <T> Query<T>.flowableOneByOne(strategy: BackpressureStrategy = BackpressureStrategy.BUFFER): Flowable<T>
fun <T> Query<T>.observable(): Observable<MutableList<T>>
fun <T> Query<T>.single(): Single<MutableList<T>>

abstract class RxBoxStore

RxBoxStore()
open static fun observable(boxStore: BoxStore!): Observable<Class<Any!>!>!

abstract class RxQuery

RxQuery()
open static fun <T : Any!> flowableOneByOne(query: Query<T>!): Flowable<T>!
open static fun <T : Any!> flowableOneByOne(query: Query<T>!, strategy: BackpressureStrategy!): Flowable<T>!
open static fun <T : Any!> observable(query: Query<T>!): Observable<MutableList<T>!>!
open static fun <T : Any!> single(query: Query<T>!): Single<MutableList<T>!>!

package io.objectbox.rx3

io.objectbox.query.Query

fun <T> Query<T>.flowableOneByOne(strategy: BackpressureStrategy = BackpressureStrategy.BUFFER): Flowable<T>
fun <T> Query<T>.observable(): Observable<MutableList<T>>
fun <T> Query<T>.single(): Single<MutableList<T>>

abstract class RxBoxStore

RxBoxStore()
open static fun observable(boxStore: BoxStore!): Observable<Class<Any!>!>!

abstract class RxQuery

RxQuery()
open static fun <T : Any!> flowableOneByOne(query: Query<T>!): Flowable<T>!
open static fun <T : Any!> flowableOneByOne(query: Query<T>!, strategy: BackpressureStrategy!): Flowable<T>!
open static fun <T : Any!> observable(query: Query<T>!): Observable<MutableList<T>!>!
open static fun <T : Any!> single(query: Query<T>!): Single<MutableList<T>!>!