Skip to content

Commit a85276b

Browse files
committed
add some [weak self] captures
1 parent 306af90 commit a85276b

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

Sources/SwiftOCADevice/OCC/ControlClasses/Agents/Grouper.swift

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -532,7 +532,7 @@ private extension OcaGrouper {
532532
guard connectionStateMonitors[connection] == nil else {
533533
return
534534
}
535-
connectionStateMonitors[connection] = Task { @OcaConnection in
535+
connectionStateMonitors[connection] = Task { @OcaConnection [weak self] in
536536
var hasReconnectedAtLeastOnce = false
537537

538538
for try await connectionState in connection.connectionState {
@@ -552,7 +552,7 @@ private extension OcaGrouper {
552552
}
553553

554554
if let changeType {
555-
try? await notifySubscribers(group: nil, changeType: changeType)
555+
try? await self?.notifySubscribers(group: nil, changeType: changeType)
556556
}
557557
}
558558
}

Sources/SwiftOCADevice/OCC/ControlClasses/Managers/LockManager.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ public class OcaLockManager: OcaManager {
8282
let lockWaiter = LockWaiter(continuation: continuation)
8383
Task { @OcaDevice in self.lockWaiters[lockWaiterID] = lockWaiter }
8484

85-
lockWaiter.task = Task {
85+
lockWaiter.task = Task { [weak self] in
8686
for await _ in target.lockStateSubject
8787
.filter({ $0.lockState == .noLock })
8888
{

Sources/SwiftOCADevice/OCP.1/Backend/IORing/Ocp1IORingController.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,7 @@ actor Ocp1IORingStreamController: Ocp1IORingControllerPrivate, CustomStringConve
110110
connectionPrefix = OcaTcpConnectionPrefix
111111
}
112112

113-
receiveMessageTask = Task { [self] in
113+
receiveMessageTask = Task {
114114
do {
115115
repeat {
116116
let messages = try await OcaDevice.receiveMessages { try await socket.read(

0 commit comments

Comments
 (0)