[#2065] Fix NPE in AbstractOioByteChannel during write to the socket
This commit is contained in:
parent
e965318398
commit
e136227ee6
@ -156,7 +156,10 @@ public abstract class AbstractOioByteChannel extends AbstractOioChannel {
|
||||
protected void doWrite(ChannelOutboundBuffer in) throws Exception {
|
||||
for (;;) {
|
||||
Object msg = in.current();
|
||||
|
||||
if (msg == null) {
|
||||
// nothing left to write
|
||||
break;
|
||||
}
|
||||
if (msg instanceof ByteBuf) {
|
||||
ByteBuf buf = (ByteBuf) msg;
|
||||
while (buf.isReadable()) {
|
||||
|
Loading…
Reference in New Issue
Block a user