From ddc87f339f441fe5b62455606cf6ed6fb8dbc461 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Lo=C3=AFc=20Hoguin?= Date: Thu, 26 Sep 2019 13:40:26 +0200 Subject: Remove UnprocessedStreams from the gun_down message --- src/gun.erl | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'src/gun.erl') diff --git a/src/gun.erl b/src/gun.erl index ddd38c8..c596764 100644 --- a/src/gun.erl +++ b/src/gun.erl @@ -758,7 +758,7 @@ flush_pid(ServerPid) -> receive {gun_up, ServerPid, _} -> flush_pid(ServerPid); - {gun_down, ServerPid, _, _, _, _} -> + {gun_down, ServerPid, _, _, _} -> flush_pid(ServerPid); {gun_inform, ServerPid, _, _, _} -> flush_pid(ServerPid); @@ -1423,8 +1423,8 @@ disconnect(State0=#state{owner=Owner, status=Status, opts=Opts, %% We closed the socket, discard any remaining socket events. disconnect_flush(State), %% @todo Stop keepalive timeout, flush message. - {KilledStreams, UnprocessedStreams} = Protocol:down(ProtoState), - Owner ! {gun_down, self(), Protocol:name(), Reason, KilledStreams, UnprocessedStreams}, + KilledStreams = Protocol:down(ProtoState), + Owner ! {gun_down, self(), Protocol:name(), Reason, KilledStreams}, Retry = maps:get(retry, Opts, 5), case Retry of 0 when Reason =:= normal -> -- cgit v1.2.3