Skip to content

Commit

Permalink
refactoring
Browse files Browse the repository at this point in the history
  • Loading branch information
Nikita Koksharov committed Jun 22, 2024
1 parent e6dce78 commit 04d7eda
Showing 1 changed file with 0 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -250,10 +250,6 @@ protected void decodeCommand(Channel channel, ByteBuf in, QueueCommand data, int
}

protected void sendNext(Channel channel) {
if (!(Thread.currentThread() instanceof FastThreadLocalThread)) {
return;
}

Queue<QueueCommandHolder> queue = channel.attr(CommandsQueue.COMMANDS_QUEUE).get();
queue.poll();
state(null);
Expand Down

0 comments on commit 04d7eda

Please sign in to comment.