io.requery.reactivex

Class ReactiveResult<E>

java.lang.Object

io.requery.query.ResultDelegate<E>

io.requery.reactivex.ReactiveResult<E>

Type Parameters:

E - element type

All Implemented Interfaces:

QueryWrapper, Result<E>, TransactionListenable, CloseableIterable<E>, AutoCloseable, Iterable<E>

public class ReactiveResult<E>
extends ResultDelegate<E>
implements QueryWrapper, TransactionListenable

Result type with RxJava 2.0 conversion methods.

Field Summary

Fields inherited from class io.requery.query.ResultDelegate

delegate

Method Summary

Modifier and Type	Method and Description
void	addTransactionListener(Supplier<TransactionListener> supplier)
io.reactivex.Flowable<E>	flowable() Converts the result stream to a Flowable.
io.reactivex.Maybe<E>	maybe() Converts the result stream to a Maybe value, return the first element if present or completes if no results.
io.reactivex.Observable<E>	observable() Converts the result stream to a Observable.
io.reactivex.Observable<ReactiveResult<E>>	observableResult() Creates an Observable that emits this result initially and then again whenever commits that may affect the query result are made from within the same EntityStore from where this instance originated.
QueryElement	unwrapQuery()

Methods inherited from class io.requery.query.ResultDelegate

close, collect, each, first, firstOr, firstOr, firstOrNull, iterator, iterator, stream, toList, toMap, toMap

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Method Detail

flowable

@CheckReturnValue
public io.reactivex.Flowable<E> flowable()

Converts the result stream to a Flowable. When the flowable terminates this result instance will be closed.

Returns:

flowable stream of the results of this query.

maybe

@CheckReturnValue
public io.reactivex.Maybe<E> maybe()

Converts the result stream to a Maybe value, return the first element if present or completes if no results.

Returns:

maybe instance of the results of this query.

observable

@CheckReturnValue
public io.reactivex.Observable<E> observable()

Converts the result stream to a Observable. When the observable terminates this result instance will be closed.

Returns:

observable stream of the results of this query.

observableResult

@CheckReturnValue
public io.reactivex.Observable<ReactiveResult<E>> observableResult()

Creates an Observable that emits this result initially and then again whenever commits that may affect the query result are made from within the same EntityStore from where this instance originated.

Returns:

Observable instance of this result that is triggered whenever changes that may affect the query are made.

addTransactionListener

public void addTransactionListener(Supplier<TransactionListener> supplier)

Specified by:

addTransactionListener in interface TransactionListenable

unwrapQuery

public QueryElement unwrapQuery()

Specified by:

unwrapQuery in interface QueryWrapper