@Test public void testChannelReadComplete() throws Exception { decoder.channelReadComplete(channelHandlerContext); verify(channelHandlerContext).flush(); }
@Override public void channelReadComplete(ChannelHandlerContext ctx) { ctx.flush(); }
MessageDecoder extends SimpleChannelInboundHandler<ByteBuf> { @Override public void channelReadComplete(ChannelHandlerContext ctx) { ctx.flush(); } }
MessageDecoder extends SimpleChannelInboundHandler<ByteBuf> { @Override public void channelReadComplete(ChannelHandlerContext ctx) { ctx.flush(); } private  MessageDecoder(SxpNode owner, Profile profile); }
MessageDecoder extends SimpleChannelInboundHandler<ByteBuf> { @Override public void channelReadComplete(ChannelHandlerContext ctx) { ctx.flush(); } private  MessageDecoder(SxpNode owner, Profile profile); static ChannelInboundHandler createClientProfile(SxpNode owner); static ChannelInboundHandler createServerProfile(SxpNode owner); static void sendErrorMessage(ChannelHandlerContext ctx, ErrorMessageException messageValidationException,
            SxpConnection connection); @Override void channelActive(ChannelHandlerContext ctx); @Override void channelInactive(ChannelHandlerContext ctx); @Override void channelRead0(ChannelHandlerContext ctx, ByteBuf message); @Override void channelReadComplete(ChannelHandlerContext ctx); @Override void exceptionCaught(ChannelHandlerContext ctx, Throwable cause); }
MessageDecoder extends SimpleChannelInboundHandler<ByteBuf> { @Override public void channelReadComplete(ChannelHandlerContext ctx) { ctx.flush(); } private  MessageDecoder(SxpNode owner, Profile profile); static ChannelInboundHandler createClientProfile(SxpNode owner); static ChannelInboundHandler createServerProfile(SxpNode owner); static void sendErrorMessage(ChannelHandlerContext ctx, ErrorMessageException messageValidationException,
            SxpConnection connection); @Override void channelActive(ChannelHandlerContext ctx); @Override void channelInactive(ChannelHandlerContext ctx); @Override void channelRead0(ChannelHandlerContext ctx, ByteBuf message); @Override void channelReadComplete(ChannelHandlerContext ctx); @Override void exceptionCaught(ChannelHandlerContext ctx, Throwable cause);  }