Package com.couchbase.client.java.query
Class ReactiveQueryResult
- java.lang.Object
-
- com.couchbase.client.java.query.ReactiveQueryResult
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Mono<QueryMetaData>
metaData()
Returns aMono
containing aQueryMetaData
, giving access to the additional metadata associated with this query.<T> Flux<T>
rowsAs(Class<T> target)
Get aFlux
which publishes the rows that were fetched by the query which are then decoded to the requested entity class The flux can complete successfully or throw -DecodingFailedException
when the decoding cannot be completed successfullyFlux<JsonObject>
rowsAsObject()
Get aFlux
which publishes the rows that were fetched by the query which are then decoded toJsonObject
-
-
-
Method Detail
-
rowsAsObject
public Flux<JsonObject> rowsAsObject()
Get aFlux
which publishes the rows that were fetched by the query which are then decoded toJsonObject
- Returns:
Flux
-
rowsAs
public <T> Flux<T> rowsAs(Class<T> target)
Get aFlux
which publishes the rows that were fetched by the query which are then decoded to the requested entity class The flux can complete successfully or throw -DecodingFailedException
when the decoding cannot be completed successfully- Parameters:
target
- target class for converting the query row- Returns:
Flux
-
metaData
public Mono<QueryMetaData> metaData()
Returns aMono
containing aQueryMetaData
, 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.
-
-