code: @Override
  	public void write(byte[] b, int off, int len) throws PacketException {
  		baq.add(b, off, len);
  		while (packetSize > 0 || (packetSize = parser.getSize(baq.array(),
  				baq.offset(), baq.length())) > 0) {
  			if (baq.length() < packetSize) {
  				return;
  			}
  			consumer.accept(baq.array(), baq.offset(), packetSize);
  			baq.remove(packetSize);
  			packetSize = 0;
  		}
  	}
docs: Parse packets when data arrived. This routine will consume every successfully
  parsed packet by calling {@link PacketConsumer#accept(byte[], int, int)}.