Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public void inboundBufferUpdated(ChannelHandlerContext ctx) {
- if (ctx.hasInboundByteBuffer()) {
- ByteBuf buf = ctx.inboundByteBuffer();
- ...
- } else {
- Queue<MyMessage> buf = ctx.inboundMessageBuffer();
- for (;;) {
- MyMessage msg = buf.poll();
- if (msg == null) {
- break;
- }
- ...
- }
- }
- }
Add Comment
Please, Sign In to add comment