Set message processing asynchronous (#454)

archethic-foundation · Jul 18, 2022 · 051e8c9 · 051e8c9
1 parent a370fd5
commit 051e8c9
Showing 1 changed file with 10 additions and 6 deletions.
diff --git a/lib/archethic/p2p/listener_protocol/broadway_pipeline.ex b/lib/archethic/p2p/listener_protocol/broadway_pipeline.ex
@@ -8,6 +8,7 @@ defmodule Archethic.P2P.ListenerProtocol.BroadwayPipeline do
   alias Archethic.P2P.Message
   alias Archethic.P2P.MessageEnvelop
   alias Archethic.P2P.Client
+  alias Archethic.TaskSupervisor
 
   alias Broadway.Message, as: BroadwayMessage
 
@@ -40,13 +41,16 @@ defmodule Archethic.P2P.ListenerProtocol.BroadwayPipeline do
     #    start_time = System.monotonic_time(:millisecond)
 
     BroadwayMessage.update_data(message, fn {socket, transport, data} ->
-      message =
-        data
-        |> decode()
-        |> process()
-        |> encode()
+      Task.Supervisor.async_nolink(TaskSupervisor, fn ->
+        message =
+          data
+          |> decode()
+          |> process()
+          |> encode()
+
+        transport.send(socket, message)
+      end)
 
-      transport.send(socket, message)
       #      end_time = System.monotnonic_time(:millisecond)
       #      Logger.debug("Request processed in #{end_time - start_time} ms")
     end)