Deployment and lifecycle management for Nix
agent: directly send call response
+1
-2
+1
-2
agent/lib/sower_agent/socket_client.ex
+1
-2
agent/lib/sower_agent/socket_client.ex
···
33
33
@impl Slipstream
34
34
def handle_call({event, params}, _from, socket) do
35
35
{:ok, ref} = push(socket, "agent:#{Storage.read().agent_sid}", event, params)
36
-
{:ok, response} = await_reply(ref)
37
-
{:reply, {:ok, response}, socket}
36
+
{:reply, await_reply(ref), socket}
38
37
end
39
38
40
39
@impl Slipstream