Fixed wait(for:fileDescriptor:)

colemancda · colemancda · commit c67494ec7bf3 · 2023-05-13T04:34:05.000-07:00
diff --git a/Sources/Socket/SocketManager/AsyncSocketManager.swift b/Sources/Socket/SocketManager/AsyncSocketManager.swift
@@ -267,6 +267,10 @@ private extension AsyncSocketManager {
         try await withThrowingContinuation(for: fileDescriptor) { (continuation: SocketContinuation<(), Swift.Error>) -> () in
             // store pending continuation
             Task {
+                guard await socket.pendingEvents.contains(events) == false else {
+                    continuation.resume()
+                    return
+                }
                 await socket.queue(events, continuation)
             }
         }

Original file line number	Diff line number	Diff line change
`@@ -267,6 +267,10 @@ private extension AsyncSocketManager {`
`267`	`267`	`try await withThrowingContinuation(for: fileDescriptor) { (continuation: SocketContinuation<(), Swift.Error>) -> () in`
`268`	`268`	`// store pending continuation`
`269`	`269`	`Task {`
	`270`	`+ guard await socket.pendingEvents.contains(events) == false else {`
	`271`	`+ continuation.resume()`
	`272`	`+ return`
	`273`	`+ }`
`270`	`274`	`await socket.queue(events, continuation)`
`271`	`275`	`}`
`272`	`276`	`}`