From 2c33866fefb8e84284727138bc14a9af78d6d36a Mon Sep 17 00:00:00 2001 From: Chris McCord Date: Fri, 6 Sep 2024 13:17:05 -0400 Subject: [PATCH] debug --- lib/flame/runner.ex | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/lib/flame/runner.ex b/lib/flame/runner.ex index 31017f0..6a6056a 100644 --- 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)