gistfile1.txt

    private void write(final ChannelHandlerContext ctx) {
        synchronized (lock) {
            while (true) {
                int pending = transport.pending();
                if (pending > 0) {
                    final int size = pending - offset;
                    if (size > 0) {
                        ByteBuf buffer = Unpooled.buffer(size);
                        ByteBuffer head = transport.head();
                        head.position(offset);
                        buffer.writeBytes(head);
                        ChannelFuture chf = ctx.writeAndFlush(buffer);
                        offset += size;
                        chf.addListener(new ChannelFutureListener() {
                            @Override
                            public void operationComplete(ChannelFuture chf) {
                                if (chf.isSuccess()) {
                                    synchronized (lock) {
                                        transport.pop(size);
                                        offset -= size;
                                    }
                                    write(ctx); // <<<< I don't like this!!!!!
                                    dispatch();
                                } else {
                                    // ???
                                }
                            }
                        });
                    } else {
                        return;
                    }
                } else {
                    if (pending < 0) {
                        closeOnFlush(ctx.channel());
                    }
                    return;
                }
            }
        }
    }