code: public static <E extends Exception, E2 extends Exception> void parse(final Reader reader, final long lineOffset, final long count,
              final int processThreadNum, final int queueSize, final Try.Consumer<String, E> lineParser, final Try.Runnable<E2> onComplete)
              throws UncheckedIOException, E, E2 {
          Iterables.parse(new LineIterator(reader), lineOffset, count, processThreadNum, queueSize, lineParser, onComplete);
      }
docs: Parse the specified Reader line by line.
  
  @param reader
  @param lineOffset
  @param count
  @param processThreadNum new threads started to parse/process the lines/records
  @param queueSize size of queue to save the processing records/lines loaded from source data. Default size is 1024.
  @param lineParser
  @param onComplete