Fixed wait(for:fileDescriptor:)

PureSwift · May 13, 2023 · c67494e · c67494e
1 parent 322cd72
commit c67494e
Showing 1 changed file with 4 additions and 0 deletions.
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)
             }
         }