Worked like a charm.
defp send_message(conn, msg) do
sse_msg = make_message(msg)
conn |> chunk(sse_msg)
end
defp sleep_until_client_exit(conn, pid) do
Process.sleep(5000)
case send_message(conn, %{heartbeat: true}) do
{:ok, ^conn} ->
sleep_until_client_exit(conn, pid)
{:error, reason} ->
IO.inspect(reason)
conn
_ ->
sleep_until_client_exit(conn, pid)
end
end






















