public <T> Builder<T> readFromTiny(String name, Collection<T> items) {
      WorkQueue<T> queue = new WorkQueue<>(prefix + "_" + name, items.size(), 1, stats);
      Consumer<T> writer = queue.threadLocalWriter();
      for (T item : items) {
        writer.accept(item);
      }
      queue.close();
      return readFromQueue(queue);
    }
Populates an initial queue with {@code items} for subsequent steps to process but does not kick off a worker
thread.
planetiler-core/src/main/java/com/onthegomap/planetiler/worker/WorkerPipeline.java