Skip to content

Commit 09981a5

Browse files
committed
Scala FIT performer: supporting SDK_KV cap
And fixing some bugs. Change-Id: I77fbc7449e8d00524925fdbcc986f754602b0494 Reviewed-on: https://review.couchbase.org/c/couchbase-jvm-clients/+/202981 Tested-by: Build Bot <[email protected]> Reviewed-by: Graham Pople <[email protected]>
1 parent 4a308df commit 09981a5

File tree

6 files changed

+1067
-12
lines changed

6 files changed

+1067
-12
lines changed

scala-fit-performer/src/main/scala/com/couchbase/client/performer/scala/ReactiveScalaSdkCommandExecutor.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@ package com.couchbase.client.performer.scala
1818
import com.couchbase.client.performer.core.commands.SdkCommandExecutor
1919
import com.couchbase.client.performer.core.perf.{Counters, PerRun}
2020
import com.couchbase.client.performer.core.util.TimeUtil.getTimeNow
21+
import com.couchbase.client.performer.scala.Content.{ContentJson, ContentString}
2122
import com.couchbase.client.performer.scala.ScalaSdkCommandExecutor._
2223
import com.couchbase.client.performer.scala.kv.LookupInHelper
2324
import com.couchbase.client.performer.scala.util.{ClusterConnection, ScalaFluxStreamer}
@@ -92,7 +93,7 @@ class ReactiveScalaSdkCommandExecutor(val connection: ClusterConnection, val cou
9293
if (options == null) collection.get(docId).block()
9394
else collection.get(docId, options).block()
9495
result.setElapsedNanos(System.nanoTime - start)
95-
if (op.getReturnResult) populateResult(request, result, r)
96+
if (op.getReturnResult) populateResult(Some(request.getContentAs), result, r)
9697
else setSuccess(result)
9798
} else if (op.hasRemove) {
9899
val request = op.getRemove

0 commit comments

Comments
 (0)