defmodule Esperantisto do def process_books() do Esperantisto.Text.iter_files() |> Task.async_stream(Esperantisto.Saver, :start, [], timeout: :infinity, max_concurency: 16) |> Stream.run() end end