We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a041573 commit af2a121Copy full SHA for af2a121
Sources/SwiftOCA/OCP.1/Ocp1MessageBatcher.swift
@@ -94,9 +94,11 @@ final class Ocp1MessageBatcher: Sendable {
94
private func startPeriodicDequeue() {
95
guard periodicTask == nil else { return }
96
97
- periodicTask = Task {
+ let dequeueInterval = dequeueInterval
98
+
99
+ periodicTask = Task { [weak self, dequeueInterval] in
100
try await Task.sleep(for: dequeueInterval) // will check for cancellation
- try await dequeue()
101
+ try await self?.dequeue()
102
}
103
104
0 commit comments