code: public void closeCurrentFile() {
      try {
        this.closer.close();
      } catch (IOException e) {
        if (this.currentFile != null) {
          LOG.error("Failed to close file: " + this.currentFile, e);
        }
      }
    }
docs: Closes the current file being read.