diff --git a/apps/emqx/src/emqx_quic_data_stream.erl b/apps/emqx/src/emqx_quic_data_stream.erl index 24dd71c29..61c13bdee 100644 --- a/apps/emqx/src/emqx_quic_data_stream.erl +++ b/apps/emqx/src/emqx_quic_data_stream.erl @@ -182,7 +182,8 @@ handle_stream_data( %% {ok, State} %% end. -passive(_Stream, undefined, S) -> +passive(Stream, undefined, S) -> + quicer:setopt(Stream, active, 10), {ok, S}. stream_closed( diff --git a/apps/emqx/src/emqx_quic_stream.erl b/apps/emqx/src/emqx_quic_stream.erl index 6fb7b0816..667ddb2b0 100644 --- a/apps/emqx/src/emqx_quic_stream.erl +++ b/apps/emqx/src/emqx_quic_stream.erl @@ -270,8 +270,9 @@ start_completed(_Stream, #{status := Other} = Prop, S) -> %% {stop, unimpl}. -spec passive(stream_handle(), undefined, cb_data()) -> cb_ret(). -passive(_Stream, undefined, _S) -> - {stop, unimpl}. +passive(Stream, undefined, S) -> + quicer:setopt(Stream, active, 10), + {ok, S}. -spec stream_closed(stream_handle(), quicer:stream_closed_props(), cb_data()) -> cb_ret(). stream_closed(