diff options
| author | Sergei Shuvatov <[email protected]> | 2022-03-08 12:27:23 +0100 |
|---|---|---|
| committer | Loïc Hoguin <[email protected]> | 2022-03-08 12:32:35 +0100 |
| commit | f6a79d54a85ceb16cc5e6bd58173733228f00389 (patch) | |
| tree | fafb6bb63806a15503782c7b6178fbf734a992bf | |
| parent | b52a570377837fcee617114feb24aba8af4f24cf (diff) | |
| download | gun-f6a79d54a85ceb16cc5e6bd58173733228f00389.tar.gz gun-f6a79d54a85ceb16cc5e6bd58173733228f00389.tar.bz2 gun-f6a79d54a85ceb16cc5e6bd58173733228f00389.zip | |
Fix flushing by stream reference
| -rw-r--r-- | src/gun.erl | 4 |
1 files changed, 3 insertions, 1 deletions
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, _, _} -> |