Uploaded image for project: 'Java Couchbase JVM Core'
  1. Java Couchbase JVM Core
  2. JVMCBC-1113

TransactionQueryResult.rowsAsObject() is not a flux - therefore requires all the rows be instantiated at once.

    XMLWordPrintable

Details

    • Improvement
    • Resolution: Incomplete
    • Major
    • None
    • None
    • transactions
    • None
    • 1

    Description

      }).flatMapMany(o -> o instanceof ReactiveQueryResult 
        ? ((ReactiveQueryResult) o).rowsAsObject()
      		 
        : Flux.fromIterable(((TransactionQueryResult) o).rowsAsObject())).flatMap(row -> {

      Attachments

        No reviews matched the request. Check your Options in the drop-down menu of this sections header.

        Activity

          People

            graham.pople Graham Pople
            michael.reiche Michael Reiche
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Gerrit Reviews

                There are no open Gerrit changes

                PagerDuty