Class ReactiveQueryResult


  • @Volatile
    public class ReactiveQueryResult
    extends Object
    Reactive result that fetch parts of the N1ql Query responses reactively
    Since:
    3.0.0
    • 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 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
      • meta

        public Mono<QueryMeta> meta()
        Returns a Mono containing a QueryMeta, 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.