Uploaded image for project: 'Scala Couchbase Client'
  1. Scala Couchbase Client
  2. SCBC-414

calls to convertReplica(result, environment, None) do not use options.transcoder

    XMLWordPrintable

Details

    • Task
    • Resolution: Fixed
    • Major
    • 1.5.3
    • None
    • None
    • None
    • 1
    • SDK02: V.Search, maxTTL=-1

    Description

      Suggest release notes: All forms of `getAnyReplica()` and `getAllReplicas()` will now use the `Transcoder` provided as an option.

      In AsyncCollection and ReactiveCollection. The calls should use options.transcoder.

      def getAllReplicas(
      id: String,
      options: GetAllReplicasOptions
      ): Seq[Future[GetReplicaResult]] =

      { // With the move to kvOps (and Protostellar support), we don't know how many replicas we're // getting until we've got them all. Previously we would check the config for this information. // Since the API here returns a Seq and not a Future, there is unfortunately // no option but to block & buffer the stream and return already completed/failed Futures. // Users that require a true streaming solution should use the reactive version. convert(kvOps.getAllReplicasReactive(convert(options), id)) .map(result => convertReplica(result, environment, None)) .collectSeq() .block(options.timeout) .map(result => Future.successful(result)) }

      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:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Gerrit Reviews

                There are no open Gerrit changes

                PagerDuty