diff --git a/notification/src/main/kotlin/com/backgu/amaker/notification/service/adapter/RealTimeUserHandlerAdapter.kt b/notification/src/main/kotlin/com/backgu/amaker/notification/service/adapter/RealTimeUserHandlerAdapter.kt index 8c9e8c8e..7d82cac8 100644 --- a/notification/src/main/kotlin/com/backgu/amaker/notification/service/adapter/RealTimeUserHandlerAdapter.kt +++ b/notification/src/main/kotlin/com/backgu/amaker/notification/service/adapter/RealTimeUserHandlerAdapter.kt @@ -33,9 +33,10 @@ class RealTimeUserHandlerAdapter( val realTimeServerSet: Set = realTimeService.findByIdsToSet(sessions.mapTo(mutableSetOf()) { it.realtimeId }) val successUser = - realTimeServerSet.map { - realTimeHandler.handleUserRealTimeNotification(listOf(notification.userId), it, notification) - } + realTimeServerSet + .map { + realTimeHandler.handleUserRealTimeNotification(notification.userId, it, notification) + }.flatten() if (successUser.isEmpty()) { applicationEventPublisher.publishEvent(