From 5065bad00b6f9cdadd0096e7440eb9a81dbd5280 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Christina=20Dahl=C3=A9n?= <85930202+kickster97@users.noreply.github.com> Date: Fri, 24 Jan 2025 13:30:52 +0100 Subject: [PATCH] Update src/lavinmq/mqtt/broker.cr MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: Carl Hörberg --- src/lavinmq/mqtt/broker.cr | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/lavinmq/mqtt/broker.cr b/src/lavinmq/mqtt/broker.cr index 675a410ac4..d599f00be0 100644 --- a/src/lavinmq/mqtt/broker.cr +++ b/src/lavinmq/mqtt/broker.cr @@ -32,8 +32,8 @@ module LavinMQ def session_present?(client_id : String, clean_session) : Bool return false if clean_session - session = sessions[client_id]? - return false if session.nil? || session.clean_session? + session = sessions[client_id]? || return false + return false if session.clean_session? true end