gistfile1.java

    private void sendNumbers() {
        // Do not send more than 4096 numbers.
        boolean finished = false;
        MessageBuf<Object> out = ctx.nextOutboundMessageBuffer();
        while (out.size() < 4096) {
            if (i <= count) {
                out.add(Integer.valueOf(i));
                i ++;
            } else {
                finished = true;
                break;
            }
        }

        ChannelFuture f = ctx.flush();
        if (!finished) {
            f.addListener(SEND_NUMBERS);
        }
    }

    private final ChannelFutureListener SEND_NUMBERS = new ChannelFutureListener() {
        @Override
        public void operationComplete(ChannelFuture future) throws Exception {
            if (future.isSuccess()) {
                sendNumbers();
            }
        }
    };