Fixed dequeue events

colemancda · colemancda · commit 02fd38815cea · 2023-05-13T06:04:21.000-07:00
diff --git a/Sources/Socket/SocketManager/AsyncSocketManager.swift b/Sources/Socket/SocketManager/AsyncSocketManager.swift
@@ -484,12 +484,12 @@ fileprivate extension AsyncSocketManager.SocketState {
         _ event: FileEvents,
         notification: Socket.Event
     ) {
+        dequeue(event)?.resume()
         guard pendingEvents.contains(event) == false else {
             return
         }
         pendingEvents.insert(event)
         continuation.yield(notification)
-        dequeue(event)?.resume()
     }
 }
 

Original file line number	Diff line number	Diff line change
`@@ -484,12 +484,12 @@ fileprivate extension AsyncSocketManager.SocketState {`
`484`	`484`	`_ event: FileEvents,`
`485`	`485`	`notification: Socket.Event`
`486`	`486`	`) {`
	`487`	`+ dequeue(event)?.resume()`
`487`	`488`	`guard pendingEvents.contains(event) == false else {`
`488`	`489`	`return`
`489`	`490`	`}`
`490`	`491`	`pendingEvents.insert(event)`
`491`	`492`	`continuation.yield(notification)`
`492`		`- dequeue(event)?.resume()`
`493`	`493`	`}`
`494`	`494`	`}`
`495`	`495`