diff --git a/apps/emqx/src/emqx_session_router.erl b/apps/emqx/src/emqx_session_router.erl index 47e4bdf74..1567f9e62 100644 --- a/apps/emqx/src/emqx_session_router.erl +++ b/apps/emqx/src/emqx_session_router.erl @@ -243,8 +243,8 @@ handle_call(Req, _From, State) -> handle_cast({delete_routes, SessionID, Subscriptions}, State) -> %% TODO: Make a batch for deleting all routes. - Fun = fun({Topic, _}) -> do_delete_route(Topic, SessionID) end, - ok = lists:foreach(Fun, maps:to_list(Subscriptions)), + Fun = fun(Topic, _) -> do_delete_route(Topic, SessionID) end, + ok = maps:foreach(Fun, Subscriptions), {noreply, State}; handle_cast({resume_end, SessionID, Pid}, State) -> case emqx_utils_ets:lookup_value(?SESSION_INIT_TAB, SessionID) of