io.requery.rx

Class RxResult<E>

java.lang.Object

io.requery.query.ResultDelegate<E>

io.requery.rx.RxResult<E>

Type Parameters:

E - element type

All Implemented Interfaces:

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

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

Result type with RxJava 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)
rx.Observable<E>	toObservable() Converts the result stream to a Observable.
rx.Observable<RxResult<E>>	toSelfObservable() 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

toObservable

@CheckReturnValue
public rx.Observable<E> toObservable()

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.

toSelfObservable

@CheckReturnValue
public rx.Observable<RxResult<E>> toSelfObservable()

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