address code review comments (zio#923)

Author: mberndt123

modules/redis/src/main/scala/zio/redis/internal/ClusterExecutor.scala

@@ -51,7 +51,7 @@ private[redis] final class ClusterExecutor private (
         case success            => ZIO.succeed(success)
       }.catchSome[Any, RedisError, RespValue] {
         case e: RedisError.Ask   => executeAsk(e.address)
-        case _: RedisError.Moved => refreshConnect(config.requestQueueSize) *> execute(keySlot)
+        case _: RedisError.Moved => refreshConnect *> execute(keySlot)
       }
       recover.retry(retryPolicy)
     }
@@ -79,11 +79,11 @@ private[redis] final class ClusterExecutor private (
       ZIO.fromOption(executorOpt).catchAll(_ => enrichedClusterIO)
     }
 
-  private def refreshConnect(requestQueueSize: Int): IO[RedisError, Unit] =
+  private def refreshConnect: IO[RedisError, Unit] =
     clusterConnection.updateZIO { connection =>
       val addresses = connection.partitions.flatMap(_.addresses)
       for {
-        cluster <- scope.extend[Any](initConnectToCluster(addresses, requestQueueSize))
+        cluster <- scope.extend[Any](initConnectToCluster(addresses, config.requestQueueSize))
         _       <- ZIO.foreachParDiscard(connection.executors) { case (_, es) => es.scope.close(Exit.unit) }
       } yield cluster
     }

modules/redis/src/main/scala/zio/redis/internal/RedisConnection.scala

@@ -75,7 +75,7 @@ private[redis] object RedisConnection {
     ZLayer.scoped(ZIO.serviceWithZIO[RedisConfig](create))
 
   lazy val local: ZLayer[Any, IOError, RedisConfig & RedisConnection] =
-    ZLayer.succeed(RedisConfig.Local) >+> layer
+    ZLayer.make[RedisConfig & RedisConnection](ZLayer.succeed(RedisConfig.Local), layer)
 
   def create(uri: RedisConfig): ZIO[Scope, RedisError.IOError, RedisConnection] =
     connect(new InetSocketAddress(uri.host, uri.port))

modules/redis/src/main/scala/zio/redis/internal/SingleNodeExecutor.scala

@@ -67,7 +67,7 @@ private[redis] object SingleNodeExecutor {
     RedisConnection.layer >>> makeLayer
 
   def local: ZLayer[Any, RedisError.IOError, RedisExecutor] =
-    ZLayer.succeed(RedisConfig.Local) >>> layer
+    ZLayer.make[RedisExecutor](ZLayer.succeed(RedisConfig.Local), layer)
 
   def create(connection: RedisConnection): URIO[Scope & RedisConfig, SingleNodeExecutor] =
     for {