diff --git a/Sources/AblyChat/RoomLifecycleManager.swift b/Sources/AblyChat/RoomLifecycleManager.swift index ca8141f1..6f67b8fe 100644 --- a/Sources/AblyChat/RoomLifecycleManager.swift +++ b/Sources/AblyChat/RoomLifecycleManager.swift @@ -188,7 +188,7 @@ internal actor DefaultRoomLifecycleManager, error: ARTErrorInfo) case suspended(retryOperationID: UUID, error: ARTErrorInfo) case failed(error: ARTErrorInfo) case releasing(releaseOperationID: UUID) @@ -210,7 +210,7 @@ internal actor DefaultRoomLifecycleManager Task { + logger.log(message: "Scheduling operation \(kind)", level: .debug) + return Task { + logger.log(message: "Performing scheduled operation \(kind)", level: .debug) + switch kind { + case let .retry(triggeringContributor, errorForSuspendedStatus): + await performRetryOperation( + triggeredByContributor: triggeringContributor, + errorForSuspendedStatus: errorForSuspendedStatus + ) + } + } + } + // MARK: - ATTACH operation internal func performAttachOperation() async throws { @@ -781,9 +809,16 @@ internal actor DefaultRoomLifecycleManager