gistfile1.txt

   public void pump(ByteBuf bytes)
   {
      if (bytes.readableBytes() < 8)
      {
         return;
      }


      try
      {
         synchronized (lock)
         {
             while (bytes.readerIndex() < bytes.writerIndex())
             {
                 int capacity = transport.capacity();
                 if (capacity > 0) {
                     final ByteBuffer tail = transport.tail();
                     int min = Math.min(capacity, bytes.readableBytes());
                     ByteBuffer tmp = bytes.internalNioBuffer(bytes.readerIndex(), min);
                     tail.put(tmp);
                     transport.process();
                     checkSASL();
                     dispatch();
                     bytes.readerIndex(bytes.readerIndex() + min);
                 }
             }
         }
      }
      finally
      {
         // After everything is processed we still need to check for more dispatches!
         dispatch();
      }
   }