Use tasks to process refreshing elements

Signed-off-by: Thomas Citharel <tcit@tcit.fr>
2021-03-31 18:32:37 +02:00 · 2021-03-31 18:32:37 +02:00 · fa99c09c57
parent 386dbbb3a6
commit fa99c09c57
1 changed files with 4 additions and 1 deletions
--- a/lib/federation/activity_pub/refresher.ex
+++ b/lib/federation/activity_pub/refresher.ex
@ -114,7 +114,10 @@ defmodule Mobilizon.Federation.ActivityPub.Refresher do

    Logger.debug(inspect(items))

-    Enum.each(items, &handling_element/1)
+    items
+    |> Enum.map(fn item -> Task.async(fn -> handling_element(item) end) end)
+    |> Task.await_many()
+
    Logger.debug("Finished processing a collection")
    :ok
  end