Package com.couchbase.client.java.query

Class ReactiveQueryResult

java.lang.Object

com.couchbase.client.java.query.ReactiveQueryResult

@Volatile
public class ReactiveQueryResult
extends Object

Reactive result that fetch parts of the N1ql Query responses reactively

Since:

3.0.0

Constructor Summary

Constructors

Constructor	Description
ReactiveQueryResult(QueryResponse response, JsonSerializer serializer)

Method Summary

Modifier and Type	Method	Description
Mono<QueryMetaData>	metaData()	Returns a Mono containing a QueryMetaData, giving access to the additional metadata associated with this query.
<T> Flux<T>	rowsAs(TypeRef<T> target)	Get a Flux which publishes the rows that were fetched by the query which are then decoded to the requested entity type
<T> Flux<T>	rowsAs(Class<T> target)	Get a Flux which publishes the rows that were fetched by the query which are then decoded to the requested entity class
Flux<JsonObject>	rowsAsObject()	Get a Flux which publishes the rows that were fetched by the query which are then decoded to JsonObject

Methods inherited from class java.lang.Object

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

Constructor Detail

ReactiveQueryResult

@Internal
public ReactiveQueryResult(QueryResponse response,
                           JsonSerializer serializer)

Method Detail

rowsAsObject

public Flux<JsonObject> rowsAsObject()

Get a Flux which publishes the rows that were fetched by the query which are then decoded to JsonObject

Returns:

Flux

rowsAs

public <T> Flux<T> rowsAs(Class<T> target)

Get a Flux which publishes the rows that were fetched by the query which are then decoded to the requested entity class

Parameters:

target - target class for converting the query row

Returns:

Flux

Throws:

DecodingFailureException - (async) if the decoding cannot be completed successfully

rowsAs

public <T> Flux<T> rowsAs(TypeRef<T> target)

Get a Flux which publishes the rows that were fetched by the query which are then decoded to the requested entity type

Parameters:

target - target type for converting the query row

Returns:

Flux

Throws:

DecodingFailureException - (async) if the decoding cannot be completed successfully

metaData

public Mono<QueryMetaData> metaData()

Returns a Mono containing a QueryMetaData, giving access to the additional metadata associated with this query. Note that the metadata will only be available once all rows have been received, so it is recommended that you first handle the rows in your code, and then the metadata. This will avoid buffering all the rows in-memory.