io.requery.reactor

Class ReactorResult<E>

java.lang.Object

io.requery.query.ResultDelegate<E>

io.requery.reactor.ReactorResult<E>

Type Parameters:

E - element type

All Implemented Interfaces:

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

public class ReactorResult<E>
extends ResultDelegate<E>
implements QueryWrapper

Result type with Reactor conversion methods.

Field Summary

Fields inherited from class io.requery.query.ResultDelegate

delegate

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Flux<E>	flux() Converts the result stream to a Flux.
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

flux

@CheckReturnValue
public reactor.core.publisher.Flux<E> flux()

Converts the result stream to a Flux.

Returns:

stream of the results of this query.

unwrapQuery

public QueryElement unwrapQuery()

Specified by:

unwrapQuery in interface QueryWrapper