Package io.objectbox.rx3

Class RxQuery

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

    • Constructor Summary

      Constructors 
      Constructor Description
      RxQuery()  

    • Method Summary

      All Methods Static Methods Concrete Methods 
      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<java.util.List<T>> observable​(Query<T> query)
      The returned Observable emits Query results as Lists.
      static <T> io.reactivex.rxjava3.core.Single<java.util.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 Detail

      • RxQuery

        public RxQuery()

    • Method Detail

      • 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<java.util.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<java.util.List<T>> single​(Query<T> query)
        The returned Single emits one Query result as a List.