From 91c42fed42d2ddee6953c393348bdd659ca0643f Mon Sep 17 00:00:00 2001 From: Stephen Paul Weber Date: Mon, 22 Jan 2024 14:51:25 -0500 Subject: [PATCH] Import hotfix from prod --- lib/session_manager.rb | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/lib/session_manager.rb b/lib/session_manager.rb index 80b1ffe9dcbb66c4b7d358dd8301b224aef6deee..5eac3d36839524442b0864f33801ed15a344be44 100644 --- a/lib/session_manager.rb +++ b/lib/session_manager.rb @@ -11,19 +11,19 @@ class SessionManager @error_if = error_if end - def promise_for(stanza) + def promise_for(stanza, timeout: @timeout) id = "#{stanza.to.stripped}/#{stanza.public_send(@id_msg)}" @sessions.fetch(id) do @sessions[id] = EMPromise.new - EM.add_timer(@timeout) do + EM.add_timer(timeout) do @sessions.delete(id)&.reject(Timeout.new) end @sessions[id] end end - def write(stanza) - promise = promise_for(stanza) + def write(stanza, timeout: @timeout) + promise = promise_for(stanza, timeout: timeout) @blather << stanza promise end