gistfile1.java

   /**
    * this method will change the readerIndex on bytes to the latest read position
    */
   public void pump(ByteBuf bytes)
   {
      if (bytes.readableBytes() < 8)
      {
         return;
      }


      try
      {
         synchronized (lock)
         {
             while (bytes.readableBytes() > 0)
             {
                 int capacity = transport.capacity();
                 if (capacity > 0) {
                     ByteBuffer tail = transport.tail();
                     int min = Math.min(capacity, bytes.readableBytes());
                     tail.limit(min);
                     bytes.readBytes(tail);
                     transport.process();
                     checkSASL();
                     dispatch();
                 } else  {
                     if (capacity == 0) {
                         System.out.println("abandoning: " + bytes.readableBytes());
                     } else {
                         System.out.println("transport closed, discarding: " + bytes.readableBytes());
                     }
                     bytes.skipBytes(bytes.readableBytes());
                 }
             }
         }
      }
      finally
      {
         // After everything is processed we still need to check for more dispatches!
         dispatch();
      }
   }