debug

phoenixframework · Sep 6, 2024 · 2c33866 · 2c33866
1 parent b1cbc53
commit 2c33866
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/flame/runner.ex b/lib/flame/runner.ex
@@ -307,7 +307,7 @@ defmodule FLAME.Runner do
               } = new_runner
 
               ip_port =
-                if base_sync_stream && base_sync_stream.eager do
+                if base_sync_stream do
                   {:ok, listen_socket} =
                     :gen_tcp.listen(0, [
                       :binary,
@@ -323,7 +323,7 @@ defmodule FLAME.Runner do
                   Task.start_link(fn ->
                     {:ok, socket} = :gen_tcp.accept(listen_socket)
                     Logger.info("Sending binary over TCP")
-                    :ok = :gen_tcp.send(socket, base_sync_stream.stream)
+                    Enum.each(base_sync_stream.stream, fn chunk -> :ok = :gen_tcp.send(socket, chunk) end)
                     {:ok, _ack} = :gen_tcp.recv(socket, 0)
                     :gen_tcp.close(socket)
                   end)