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
  • Method Details

    • 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.