com.holonplatform.reactor.datastore.operation

Interface ReactiveQueryAdapter<C extends com.holonplatform.core.query.QueryConfiguration>

Type Parameters:

C - Query configuration type

public interface ReactiveQueryAdapter<C extends com.holonplatform.core.query.QueryConfiguration>

Adapter to perform a reactive query execution using a QueryOperation instance, which provides both the QueryConfiguration and the QueryProjection.

The query results are provided using a Flux.

Since:

5.2.0

See Also:

ReactiveQuery

Method Summary

Modifier and Type	Method and Description
<R> reactor.core.publisher.Flux<R>	stream(com.holonplatform.core.query.QueryOperation<C,R> queryOperation) Execute a query using the provided QueryOperation and return the results as a Flux of query results.

Method Detail

stream

<R> reactor.core.publisher.Flux<R> stream(com.holonplatform.core.query.QueryOperation<C,R> queryOperation)

Execute a query using the provided QueryOperation and return the results as a Flux of query results.

Type Parameters:

R - Query results type

Parameters:

queryOperation - Query operation (not null)

Returns:

Query results Flux stream