Skip to content

Commit 6dfd5e5

Browse files
committed
Read states: rename retry delay local to avoid shadowing SignalKit delay operator
Co-authored-by: D3C0Y <decoder-dev@users.noreply.github.com>
1 parent c763d9b commit 6dfd5e5

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

‎submodules/TelegramCore/Sources/State/ManagedSynchronizePeerReadStates.swift‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -74,16 +74,16 @@ private final class SynchronizePeerReadStatesContextImpl {
7474
private func scheduleRetry(peerId: PeerId, operation: PeerReadStateSynchronizationOperation) {
7575
let failureCount = (self.failureCounts[peerId] ?? 0) + 1
7676
self.failureCounts[peerId] = failureCount
77-
let delay = min(
77+
let retryDelay = min(
7878
SynchronizePeerReadStatesContextImpl.maximumRetryInterval,
7979
SynchronizePeerReadStatesContextImpl.minimumRetryInterval * pow(2.0, Double(failureCount - 1))
8080
)
81-
Logger.shared.log("SynchronizePeerReadStates", "\(peerId): operation retry \(operation) in \(delay)s (failure \(failureCount))")
81+
Logger.shared.log("SynchronizePeerReadStates", "\(peerId): operation retry \(operation) in \(retryDelay)s (failure \(failureCount))")
8282

8383
let disposable = MetaDisposable()
8484
self.retryDisposables[peerId] = disposable
8585
disposable.set((Signal<Never, NoError>.complete()
86-
|> delay(delay, queue: self.queue)).start(completed: { [weak self] in
86+
|> delay(retryDelay, queue: self.queue)).start(completed: { [weak self] in
8787
guard let strongSelf = self else {
8888
return
8989
}

0 commit comments

Comments
 (0)