fix
This commit is contained in:
parent
36e6b9f6d9
commit
83f71711cf
@ -151,15 +151,14 @@ actor DNSCloudClient {
|
|||||||
|
|
||||||
let stream = Self.makeReceiveStream(for: connection)
|
let stream = Self.makeReceiveStream(for: connection)
|
||||||
self.receiveTask = Task { [weak self] in
|
self.receiveTask = Task { [weak self] in
|
||||||
guard let self else {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
for await data in stream {
|
for await data in stream {
|
||||||
|
guard let self else {
|
||||||
|
break
|
||||||
|
}
|
||||||
await self.handleReceivedPacket(data)
|
await self.handleReceivedPacket(data)
|
||||||
}
|
}
|
||||||
|
|
||||||
await self.didFinishReceiving(for: connection)
|
await self?.didFinishReceiving(for: connection)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user