code: protected void updateBytesRead() {
          if (log.isTraceEnabled()) {
              log.trace("updateBytesRead");
          }
          long bytesRead = getReadBytes();
          if (bytesRead >= nextBytesRead) {
              BytesRead sbr = new BytesRead((int) (bytesRead % Integer.MAX_VALUE));
              getChannel(2).write(sbr);
              nextBytesRead += bytesReadInterval;
          }
      }
docs: Update number of bytes to read next value.