Search⌘ K
AI Features
Home
Courses
Concurrent Data Processing in Elixir

Parameters of the async_stream Function

Understand how to use async_stream's parameters like max_concurrency, ordering, and timeout to optimize concurrent task execution in Elixir. Learn to adjust concurrency levels, control result ordering, handle timeouts, and improve process resilience for better performance.

We'll cover the following...

Now, let’s update notify_all/1 to use async_stream/3. However, this time, we run the stream using Enum.to_list/1:

Scala
#file path -> sender/lib/sender.ex
def notify_all(emails) do
  emails
  |> Task.async_stream(&send_email/1)
  |> Enum.to_list()
end

Here is the executable command:

Scala
Sender.notify_all(emails)

This is the output we get:

iex(1)> Sender.notify_all(emails)
Email to hello@world.com sent
Email to hola@world.com sent
Email to nihao@world.com sent
Email to konnichiwa@world.com sent
[
  ok: {:ok, "email_sent"},
  ok: {:ok, "email_sent"},
  ok: {:ok, "email_sent"},
  ok: {:ok, "email_sent"}
]

We make changes in the playground widget at the end and click the “Run” button to execute the code. The output will be similar to the Task.async/2 example. However, depending on how many logical ...