code golf

lichess-org · Sep 25, 2024 · aea879f · aea879f
1 parent 7af9d69
commit aea879f
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/src/main/scala/netty/ActorChannelConnector.scala b/src/main/scala/netty/ActorChannelConnector.scala
@@ -34,12 +34,10 @@ final private class ActorChannelConnector(
   def apply(endpoint: Endpoint, channel: Channel): Unit =
     val clientPromise = Promise[Client]()
     channel.attr(key.client).set(clientPromise.future)
-    val channelEmit: ClientEmit =
-      emitToChannel(channel, withFlush = endpoint.alwaysFlush)
-    val monitoredEmit: ClientEmit = (msg: ipc.ClientIn) =>
+    val channelEmit: ClientEmit = (msg: ipc.ClientIn) =>
       endpoint.emitCounter.increment()
-      channelEmit(msg)
-    clients ! Clients.Control.Start(endpoint.behavior(monitoredEmit), clientPromise)
+      emitToChannel(channel, withFlush = endpoint.alwaysFlush)
+    clients ! Clients.Control.Start(endpoint.behavior(channelEmit), clientPromise)
     channel.closeFuture.addListener:
       new GenericFutureListener[NettyFuture[Void]]:
         def operationComplete(f: NettyFuture[Void]): Unit =