Skip to content

Commit 891f0ff

Browse files
committed
fix : remove duplicated sse completion
1 parent 2bdb590 commit 891f0ff

File tree

2 files changed

+1
-2
lines changed

2 files changed

+1
-2
lines changed

matching-service/matching-application/app-api/src/main/kotlin/com/grepp/quizy/matching/api/sse/SseConnector.kt

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,6 @@ class SseConnector(
3434
}
3535

3636
fun disconnect(userId: UserId) {
37-
emitterRepository.findById(userId.value)?.complete()
3837
emitterRepository.remove(userId.value)
3938
matchingPoolManager.remove(userId)
4039
}

matching-service/matching-application/app-api/src/main/kotlin/com/grepp/quizy/matching/api/sse/SseSender.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,14 +27,14 @@ class SseSender(
2727
.data(objectMapper.writeValueAsString(MatchingSucceed(event.gameRoomId)))
2828
)
2929
emitter.complete()
30+
closeEmitter(event.userId)
3031
} catch (e: IOException) {
3132
closeEmitter(event.userId)
3233
emitter.completeWithError(e)
3334
}
3435
}
3536

3637
private fun closeEmitter(userId: Long) {
37-
emitterRepository.findById(userId)?.complete()
3838
emitterRepository.remove(userId)
3939
matchingPoolManager.remove(UserId(userId))
4040
}

0 commit comments

Comments
 (0)