refactor :: onError에서 complete() 제거

ByunDohwi · ByunDohwi · commit 398cf6510b56 · 2026-01-27T16:00:39.000+09:00
diff --git a/src/main/kotlin/dsm/pick2024/infrastructure/sse/SseRegistry.kt b/src/main/kotlin/dsm/pick2024/infrastructure/sse/SseRegistry.kt
@@ -71,7 +71,6 @@ class SseRegistry : SseRegistryPort {
             cleanup.run()
         }
         emitter.onError {
-            emitter.complete()
             cleanup.run()
         }
     }

Original file line number	Diff line number	Diff line change
`@@ -71,7 +71,6 @@ class SseRegistry : SseRegistryPort {`
`71`	`71`	`cleanup.run()`
`72`	`72`	`}`
`73`	`73`	`emitter.onError {`
`74`		`- emitter.complete()`
`75`	`74`	`cleanup.run()`
`76`	`75`	`}`
`77`	`76`	`}`