diff --git a/transport-native-kqueue/src/main/java/io/netty/channel/kqueue/KQueueDatagramChannel.java b/transport-native-kqueue/src/main/java/io/netty/channel/kqueue/KQueueDatagramChannel.java index b6757a7c41..c45973123e 100644 --- a/transport-native-kqueue/src/main/java/io/netty/channel/kqueue/KQueueDatagramChannel.java +++ b/transport-native-kqueue/src/main/java/io/netty/channel/kqueue/KQueueDatagramChannel.java @@ -280,7 +280,7 @@ public final class KQueueDatagramChannel extends AbstractKQueueChannel implement } // Whether all messages were written or not. - writeFilter(in.isEmpty()); + writeFilter(!in.isEmpty()); } private boolean doWriteMessage(Object msg) throws Exception {