Fix formatting

zio · Jan 4, 2023 · 485d388 · 485d388
1 parent 8bb6148
commit 485d388
Showing 1 changed file with 9 additions and 9 deletions.
diff --git a/redis/src/main/scala/zio/redis/ClusterExecutor.scala b/redis/src/main/scala/zio/redis/ClusterExecutor.scala
@@ -64,6 +64,15 @@ final case class ClusterExecutor(
     } yield result
   }
 
+  def executePubSub(command: Chunk[RespValue.BulkString]): Stream[RedisError, RespValue] =
+    ZStream.fromZIO {
+      for {
+        keySlot <- extractKeySlot(command)
+        executor <- executor(keySlot)
+        stream = executor.executePubSub(command)
+      } yield stream
+    }.flatten
+
   private def extractKeySlot(command: Chunk[RespValue.BulkString]) =
     for {
       key    <- ZIO.attempt(command(1)).orElseFail(CusterKeyError)
@@ -98,15 +107,6 @@ final case class ClusterExecutor(
         case _: RedisError.IOError | _: RedisError.ClusterRedisError => true
         case _                                                       => false
       }
-
-  def executePubSub(command: Chunk[RespValue.BulkString]): Stream[RedisError, RespValue] =
-    ZStream.fromZIO {
-      for {
-        keySlot  <- extractKeySlot(command)
-        executor <- executor(keySlot)
-        stream    = executor.executePubSub(command)
-      } yield stream
-    }.flatten
 }
 
 object ClusterExecutor {