Package io.objectbox.rx3

Class RxQuery

java.lang.Object
io.objectbox.rx3.RxQuery
public abstract class RxQuery extends Object
Static methods to Rx-ify ObjectBox queries.

  • Constructor Summary

    Constructors
    Constructor
    Description
    RxQuery()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    (package private) static <T> void
    createListItemEmitter(Query<T> query, io.reactivex.rxjava3.core.FlowableEmitter<T> emitter)
     
    static <T> io.reactivex.rxjava3.core.Flowable<T>
    flowableOneByOne(Query<T> query)
    The returned Flowable emits Query results one by one.
    static <T> io.reactivex.rxjava3.core.Flowable<T>
    flowableOneByOne(Query<T> query, io.reactivex.rxjava3.core.BackpressureStrategy strategy)
    The returned Flowable emits Query results one by one.
    static <T> io.reactivex.rxjava3.core.Observable<List<T>>
    observable(Query<T> query)
    The returned Observable emits Query results as Lists.
    static <T> io.reactivex.rxjava3.core.Single<List<T>>
    single(Query<T> query)
    The returned Single emits one Query result as a List.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • RxQuery

      public RxQuery()

  • Method Details

    • flowableOneByOne

      public static <T> io.reactivex.rxjava3.core.Flowable<T> flowableOneByOne(Query<T> query)
      The returned Flowable emits Query results one by one. Once all results have been processed, onComplete is called. Uses BackpressureStrategy.BUFFER.

    • flowableOneByOne

      public static <T> io.reactivex.rxjava3.core.Flowable<T> flowableOneByOne(Query<T> query, io.reactivex.rxjava3.core.BackpressureStrategy strategy)
      The returned Flowable emits Query results one by one. Once all results have been processed, onComplete is called. Uses given BackpressureStrategy.

    • createListItemEmitter

      static <T> void createListItemEmitter(Query<T> query, io.reactivex.rxjava3.core.FlowableEmitter<T> emitter)

    • observable

      public static <T> io.reactivex.rxjava3.core.Observable<List<T>> observable(Query<T> query)
      The returned Observable emits Query results as Lists. Never completes, so you will get updates when underlying data changes (see Query.subscribe() for details).

    • single

      public static <T> io.reactivex.rxjava3.core.Single<List<T>> single(Query<T> query)
      The returned Single emits one Query result as a List.