public <T> Bufferable<T> fromGenerator(String name, SourceStep<T> producer) {
      return fromGenerator(name, producer, 1);
    }
Adds an initial step that runs {@code producer} in 1 worker thread to produce items for this queue.
planetiler-core/src/main/java/com/onthegomap/planetiler/worker/WorkerPipeline.java