Update src/lavinmq/mqtt/broker.cr

Co-authored-by: Carl Hörberg <[email protected]>
cloudamqp · Jan 24, 2025 · 5065bad · 5065bad
1 parent 76a0edd
commit 5065bad
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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