src/main/java/com/github/wnameless/io/reader/parallel/ParallelLineReader.java
/**
   * Creates {@link CompletableFuture}s for each part of input content.
   * 
   * @param <E>
   *          the result type of each {@link CompletableFuture}
   * @param lineReaderFunction
   *          a function to process each part of the content which is read by a
   *          {@link LineReader}
   * @return a list of {@link CompletableFuture}s
   * @throws IOException
   *           if any I/O Exception happened during reading
   */
Creates  CompletableFutures for each part of input content.

@param 
the result type of each  CompletableFuture
@param lineReaderFunction
a function to process each part of the content which is read by a
LineReader
@return a list of  CompletableFutures
@throws IOException
if any I/O Exception happened during reading
Creates CompletableFutures for each part of input content . @param the result type of each CompletableFuture @param lineReaderFunction a function to process each part of the content which is read by a LineReader @return a list of CompletableFutures @throws IOException if any I / O Exception happened during reading
public <E> List<CompletableFuture<E>> readParallelly(
      LineReaderFunction<E> lineReaderFunction) throws IOException {
    if (executor == null) {
      return LineReaders.readParallelly(reader, maxLines,
          lineReaderFunction);
    } else {
      return LineReaders.readParallelly(reader, maxLines,
          lineReaderFunction, executor);
    }
  }
public < E > List < CompletableFuture < E > > readParallelly ( LineReaderFunction < E > lineReaderFunction ) throws IOException { if ( executor == null ) { return LineReaders . readParallelly ( reader , maxLines , lineReaderFunction ) ; } else { return LineReaders . readParallelly ( reader , maxLines , lineReaderFunction , executor ) ; } }
Creates {@link CompletableFuture}s for each part of input content.
Creates { @link CompletableFuture } s for each part of input content .