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

  • Method Summary

    Modifier and Type Method Description
    reactor.core.publisher.Mono<QueryMetaData> metaData()
    Returns a Mono containing a QueryMetaData, giving access to the additional metadata associated with this query.
    <T> reactor.core.publisher.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> reactor.core.publisher.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
    reactor.core.publisher.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

  • Method Details

    • rowsAsObject

      public reactor.core.publisher.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> reactor.core.publisher.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> reactor.core.publisher.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 reactor.core.publisher.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.