andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

No need to override ByteToMessageCodec.decoder.discardInboundReadBytes()

Browse Source
This commit is contained in:
Trustin Lee 2013-01-09 15:05:03 +09:00
parent ef692b0c38
commit 102563ec8f
1 changed files with 17 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
codec/src/main/java/io/netty/handler/codec/ByteToMessageCodec.java
View File

@ -57,11 +57,6 @@ public abstract class ByteToMessageCodec<INBOUND_OUT, OUTBOUND_IN>
protected INBOUND_OUT decodeLast(ChannelHandlerContext ctx, ByteBuf in) throws Exception { protected INBOUND_OUT decodeLast(ChannelHandlerContext ctx, ByteBuf in) throws Exception {
return ByteToMessageCodec.this.decodeLast(ctx, in); return ByteToMessageCodec.this.decodeLast(ctx, in);
} }
@Override
public void discardInboundReadBytes(ChannelHandlerContext ctx) throws Exception {
ByteToMessageCodec.this.discardInboundReadBytes(ctx);
}
}; };
} }
@ -76,18 +71,8 @@ public abstract class ByteToMessageCodec<INBOUND_OUT, OUTBOUND_IN>
} }
@Override @Override
public void inboundBufferUpdated(ChannelHandlerContext ctx) throws Exception { public void discardInboundReadBytes(ChannelHandlerContext ctx) throws Exception {
decoder.inboundBufferUpdated(ctx); decoder.discardInboundReadBytes(ctx);
}
@Override
public MessageBuf<OUTBOUND_IN> newOutboundBuffer(ChannelHandlerContext ctx) throws Exception {
return encoder.newOutboundBuffer(ctx);
}
@Override
public void flush(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception {
encoder.flush(ctx, promise);
} }
@Override @Override
@ -95,11 +80,26 @@ public abstract class ByteToMessageCodec<INBOUND_OUT, OUTBOUND_IN>
decoder.freeInboundBuffer(ctx); decoder.freeInboundBuffer(ctx);
} }
@Override
public MessageBuf<OUTBOUND_IN> newOutboundBuffer(ChannelHandlerContext ctx) throws Exception {
return encoder.newOutboundBuffer(ctx);
}
@Override @Override
public void freeOutboundBuffer(ChannelHandlerContext ctx) throws Exception { public void freeOutboundBuffer(ChannelHandlerContext ctx) throws Exception {
encoder.freeOutboundBuffer(ctx); encoder.freeOutboundBuffer(ctx);
} }
@Override
public void inboundBufferUpdated(ChannelHandlerContext ctx) throws Exception {
decoder.inboundBufferUpdated(ctx);
}
@Override
public void flush(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception {
encoder.flush(ctx, promise);
}
public boolean isEncodable(Object msg) throws Exception { public boolean isEncodable(Object msg) throws Exception {
return ChannelHandlerUtil.acceptMessage(encodableMessageTypes, msg); return ChannelHandlerUtil.acceptMessage(encodableMessageTypes, msg);
} }