style and scala3

akka · Jun 27, 2023 · 7e08544 · 7e08544
1 parent b3d8f6f
commit 7e08544
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/main/scala/akka/kafka/javadsl/Consumer.scala b/core/src/main/scala/akka/kafka/javadsl/Consumer.scala
@@ -93,8 +93,8 @@ object Consumer {
       control.drainAndShutdown(streamCompletion, ec)
 
     override val isShutdown: CompletionStage[Done] =
-      control.isShutdown.thenCompose[Done] { _: Any =>  // Scala 2.12 needs the types here
-        streamCompletion.thenApply[Done] { _: Any => // Scala 2.12 needs the types here
+      control.isShutdown.thenCompose[Done] { (_: Any) => // Scala 2.12 needs the types here
+        streamCompletion.thenApply[Done] { (_: Any) => // Scala 2.12 needs the types here
           Done.done()
         }
       }