%SL{data: %Sess{proxy: proxy, invocations: inv, yield: {:yield, id, dets, arg_l, arg_kw}}} =
data
) do
+ Logger.info("Handling yield #{id} - #{inspect(arg_kw)}")
+
case Enum.find(inv, fn
{_, %Invocation{request_id: ^id}, _} -> true
_ -> false
)
nil ->
+ Logger.error("No invocation for #{id} #{inspect(arg_kw)}")
:noop
end
@impl true
def handle_info(%Result{} = e, _, %SL{data: %Sess{transport: tt, transport_pid: t}} = data) do
+ Logger.info("Handling Result #{inspect(e)}")
send_to_peer(Dealer.result(e), tt, t)
{:ok, data, []}
end