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)