core / pragma.session / notifyLocalActiveSessionsImpl /

notifyLocalActiveSessionsImpl #

internal suspend fun DistributedService.notifyLocalActiveSessionsImpl(sessionManager: SessionManager, notification: ExternalNotification, batchSize: Int = DEFAULT_NOTIFY_ALL_BATCH_SIZE, batchIntervalMillis: Long = DEFAULT_NOTIFY_ALL_BATCH_INTERVAL_MILLIS, pragmaIdOf: (PragmaSession) -> UUID)

Delivers notification to every session held by this instance.

pragmaIdOf selects the calling kind’s oneof case off PragmaSession. Delivery is fire-and-forget per session so one unreachable connection cannot stall the rest; sessions that connect after the broadcast do not receive it retroactively.