From f6a79d54a85ceb16cc5e6bd58173733228f00389 Mon Sep 17 00:00:00 2001 From: Sergei Shuvatov Date: Tue, 8 Mar 2022 12:27:23 +0100 Subject: Fix flushing by stream reference --- src/gun.erl | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/gun.erl b/src/gun.erl index ddd6cec..3ca65b7 100644 --- a/src/gun.erl +++ b/src/gun.erl @@ -841,6 +841,7 @@ flush(ServerPid) when is_pid(ServerPid) -> flush(StreamRef) -> flush_ref(StreamRef). +-spec flush_pid(pid()) -> ok. flush_pid(ServerPid) -> receive {gun_up, ServerPid, _} -> @@ -871,10 +872,11 @@ flush_pid(ServerPid) -> ok end. +-spec flush_ref(stream_ref()) -> ok. flush_ref(StreamRef) -> receive {gun_inform, _, StreamRef, _, _} -> - flush_pid(StreamRef); + flush_ref(StreamRef); {gun_response, _, StreamRef, _, _, _} -> flush_ref(StreamRef); {gun_data, _, StreamRef, _, _} -> -- cgit v1.2.3