From 5ae8cd2fa3448bb538ca70be5eb53e98b61dfd76 Mon Sep 17 00:00:00 2001 From: William Yang Date: Wed, 30 Jun 2021 11:21:07 +0200 Subject: [PATCH] fix(quic): dialyzer errors --- apps/emqx/src/emqx_quic_stream.erl | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/apps/emqx/src/emqx_quic_stream.erl b/apps/emqx/src/emqx_quic_stream.erl index 64e851758..236c11ad3 100644 --- a/apps/emqx/src/emqx_quic_stream.erl +++ b/apps/emqx/src/emqx_quic_stream.erl @@ -53,7 +53,11 @@ getstat(Socket, Stats) -> end. setopts(Socket, Opts) -> - [ quicer:setopt(Socket, Opt, V) || {Opt, V} <- Opts ], + lists:foreach(fun({Opt, V}) when is_atom(Opt) -> + quicer:setopt(Socket, Opt, V); + (Opt) when is_atom(Opt) -> + quicer:setopt(Socket, Opt, true) + end, Opts), ok. getopts(_Socket, _Opts) -> @@ -65,8 +69,8 @@ getopts(_Socket, _Opts) -> {buffer,80000}]}. fast_close(Stream) -> - quicer:async_close_stream(Stream), %% Stream might be closed already. + _ = quicer:async_close_stream(Stream), ok. -spec(ensure_ok_or_exit(atom(), list(term())) -> term()).