Scala 3 fixes

src/main/scala/play/api/cache/redis/connector/RedisClientFactory.scala

@@ -147,12 +147,14 @@ private object RedisClientFactory {
 
           @SuppressWarnings(Array("org.wartremover.warts.IsInstanceOf"))
           override def afterChannelInitialized(channel: Channel): Unit = {
-            channel.pipeline.addLast(new IdleStateHandler(afterChannelTime, 0, 0)): Unit
-            channel.pipeline.addLast(new ChannelDuplexHandler() {
+            val _ = channel.pipeline.addLast(new IdleStateHandler(afterChannelTime, 0, 0))
+            val _ = channel.pipeline.addLast(new ChannelDuplexHandler() {
               @throws[Exception]
               override def userEventTriggered(ctx: ChannelHandlerContext, evt: Object): Unit =
-                if (evt.isInstanceOf[IdleStateEvent]) ctx.disconnect().sync(): Unit
-            }): Unit
+                if (evt.isInstanceOf[IdleStateEvent]) {
+                  val _ = ctx.disconnect().sync()
+                }
+            })
           }
 
         },

src/main/scala/play/api/cache/redis/connector/RedisConnectorImpl.scala

@@ -91,8 +91,8 @@ private[connector] class RedisConnectorImpl(
       key,
       value,
       new SetArgs()
-        .when(expiration.isFinite, _.px(expiration.toMillis))
-        .when(ifNotExists, _.nx()),
+        .mapWhen(expiration.isFinite, _.px(expiration.toMillis))
+        .mapWhen(ifNotExists, _.nx()),
     )
       .toScala[Option[String]]
       .map(_ contains "OK")
@@ -485,7 +485,7 @@ private[connector] object RedisConnectorImpl {
 
   implicit private class ConditionalCall[T](private val thiz: T) extends AnyVal {
 
-    def when(condition: Boolean, f: T => T): T =
+    def mapWhen(condition: Boolean, f: T => T): T =
       if (condition) f(thiz) // mutable side effect
       else thiz
 

src/test/java/play/api/cache/redis/connector/RedisCommandsMock.java → src/test/java/play/api/cache/redis/connector/AbstractRedisCommandsMock.java

@@ -6,7 +6,7 @@
 
 import java.util.List;
 
-public abstract class RedisCommandsMock implements RedisClusterAsyncCommands<String, String> {
+public abstract class AbstractRedisCommandsMock implements RedisClusterAsyncCommands<String, String> {
 
     @Override
     final public RedisFuture<String> set(String key, String value, SetArgs setArgs) {

src/test/scala/play/api/cache/redis/connector/RedisCommandsMock.scala

@@ -0,0 +1,3 @@
+package play.api.cache.redis.connector
+
+abstract class RedisCommandsMock extends AbstractRedisCommandsMock

src/test/scala/play/api/cache/redis/connector/RedisConnectorFailureSpec.scala

@@ -314,7 +314,7 @@ class RedisConnectorFailureSpec extends AsyncUnitSpec with ImplicitFutureMateria
 
         @SuppressWarnings(Array("org.wartremover.warts.Equals"))
         override def equals(obj: Any): Boolean = obj match {
-          case that: Array[?] => that.length == expected.length && that.zip(expected).forall { case (a, b) => a == b }
+          case that: Array[?] => that.length == expected.length && expected.zip(that).forall { case (a, b) => a == b }
           case _              => false
         }