Use fallback when executing Redis commands using Monix API

(cherry picked from commit 64e228c)
AVSystem · Oct 5, 2023 · 0912d96 · 0912d96
1 parent 4c24627
commit 0912d96
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/redis/src/main/scala/com/avsystem/commons/redis/ApiSubset.scala b/redis/src/main/scala/com/avsystem/commons/redis/ApiSubset.scala
@@ -160,7 +160,7 @@ trait RedisMonixApi extends RedisExecutedApi {
   type Result[A] = Task[A]
 
   def execute[A](command: RedisCommand[A]): Task[A] = Task.deferFutureAction { scheduler =>
-    executor.executeBatch(command, execConfig.copy(decodeOn = scheduler))
+    executor.executeBatch(command.batchOrFallback, execConfig.copy(decodeOn = scheduler))
   }
 
   def recoverWith[A](executed: => Task[A])(fun: PartialFunction[Throwable, Task[A]]): Task[A] =