objectbox-rxjava3 / io.objectbox.rx3 / RxQuery / flowableOneByOne

flowableOneByOne

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 BackpressureStrategy.BUFFER.

open static fun <T : Any!> flowableOneByOne(query: Query<T>!, strategy: BackpressureStrategy!): Flowable<T>!

The returned Flowable emits Query results one by one. Once all results have been processed, onComplete is called. Uses given BackpressureStrategy.