code: private void setCatchingUp() throws IOException {
      try {
        if (inputEditStream != null && inputEditStream.isInProgress()) {
          catchingUp = (inputEditStream.length() - inputEditStream.getPosition() > catchUpLag);
        } else {
          catchingUp = true;
        }
      } catch (Exception e) {
        catchingUp = true;
      }
    }
docs: Checks if the ingest is catching up.
  If the ingest is consuming finalized segment, it's assumed to be behind.
  Otherwise, catching up is based on the position of the input stream.
  @throws IOException