From 0daff68b8cb875339972cef38df606c64fffc156 Mon Sep 17 00:00:00 2001 From: Heidi Date: Sat, 24 Aug 2024 01:18:24 +0900 Subject: [PATCH] =?UTF-8?q?emitter=20remove=20=ED=95=A8=EC=88=98=20?= =?UTF-8?q?=EC=A0=9C=EA=B1=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../kotlin/com/mashup/dojo/service/NotificationService.kt | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/service/src/main/kotlin/com/mashup/dojo/service/NotificationService.kt b/service/src/main/kotlin/com/mashup/dojo/service/NotificationService.kt index df875e07..de63199b 100644 --- a/service/src/main/kotlin/com/mashup/dojo/service/NotificationService.kt +++ b/service/src/main/kotlin/com/mashup/dojo/service/NotificationService.kt @@ -55,15 +55,15 @@ class SSENotificationService : NotificationService { emitters[memberId.value] = emitter emitter.onCompletion { logger.debug { "emitter($memberId) completed successfully" } - emitters.remove(memberId.value) +// emitters.remove(memberId.value) } emitter.onError { logger.debug { "emitter error occurred: $it" } - emitters.remove(memberId.value) +// emitters.remove(memberId.value) } emitter.onTimeout { logger.debug { "emitter($memberId) timed out" } - emitters.remove(memberId.value) +// emitters.remove(memberId.value) } } }