Skip to content

Commit

Permalink
remove delegation to worker thread eventLoop
Browse files Browse the repository at this point in the history
  • Loading branch information
schlawg committed Sep 26, 2024
1 parent aa78adb commit 566be56
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/main/scala/netty/ActorChannelConnector.scala
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,7 @@ final private class ActorChannelConnector(
while channelsToFlush > 0 do
Option(flushQ.poll()) match
case Some(channel) =>
if channel.isOpen then channel.eventLoop().execute(() => channel.flush())
if channel.isOpen then channel.flush()
channelsToFlush -= 1
case _ =>
channelsToFlush = 0
Expand Down

0 comments on commit 566be56

Please sign in to comment.