Use fallback when executing Redis commands using Monix API

sebaciv · sebaciv · commit 0912d96d6679 · 2023-10-05T11:52:16.000+02:00
(cherry picked from commit 64e228c)
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] =

Original file line number	Diff line number	Diff line change
`@@ -160,7 +160,7 @@ trait RedisMonixApi extends RedisExecutedApi {`
`160`	`160`	`type Result[A] = Task[A]`
`161`	`161`
`162`	`162`	`def execute[A](command: RedisCommand[A]): Task[A] = Task.deferFutureAction { scheduler =>`
`163`		`- executor.executeBatch(command, execConfig.copy(decodeOn = scheduler))`
	`163`	`+ executor.executeBatch(command.batchOrFallback, execConfig.copy(decodeOn = scheduler))`
`164`	`164`	`}`
`165`	`165`
`166`	`166`	`def recoverWith[A](executed: => Task[A])(fun: PartialFunction[Throwable, Task[A]]): Task[A] =`