private WorkerPipeline.WorkerStep<Path, F> readPaths() {
    return (paths, consumer) -> {
      for (var path : paths) {
        try (var reader = readerFactory.apply(path)) {
          reader.readFeatures(consumer);
        }
      }
    };
  }
Returns a source that initiates a {@link WorkerPipeline} with elements from this data provider.
planetiler-core/src/main/java/com/onthegomap/planetiler/reader/SourceFeatureProcessor.java