(1..100)
|> Stream.chunk_every(20, 20, [])
|> Task.async_stream(fn x ->
Enum.each(x, fn m ->
{proxies, proxy} = App.ReleaseTasks.get_proxy proxies
IO.inspect proxy
end)
end, max_concurrency: (System.schedulers_online * 5), timeout: :infinity)
|>
Stream.run