Fix Tests

Author: swhitty

FlyingSocks/Sources/SocketPool+ePoll.swift

@@ -34,7 +34,7 @@ import CSystemLinux
 
 public extension AsyncSocketPool where Self == SocketPool<ePoll> {
     static func ePoll(maxEvents limit: Int = 20) -> SocketPool<ePoll> {
-        SocketPool(queue: ePoll(maxEvents: limit))
+        SocketPool(queue: FlyingSocks.ePoll(maxEvents: limit))
     }
 }
 

FlyingSocks/Sources/SocketPool.swift

@@ -63,6 +63,21 @@ public func makeEventQueuePool(maxEvents limit: Int = 20) -> AsyncSocketPool {
 #endif
 }
 
+#if compiler(>=5.7)
+public extension AsyncSocketPool where Self == SocketPool<Poll> {
+
+    static func make(maxEvents limit: Int = 20) -> SocketPool<some EventQueue> {
+#if canImport(Darwin)
+    return .kQueue(maxEvents: limit)
+#elseif canImport(CSystemLinux)
+    return .ePoll(maxEvents: limit)
+#else
+    return .poll(interval: .seconds(0.01))
+#endif
+    }
+}
+#endif
+
 public final actor SocketPool<Queue: EventQueue>: AsyncSocketPool {
 
     private(set) var queue: Queue

FlyingSocks/Tests/SocketPoolTests.swift

@@ -37,13 +37,20 @@ final class SocketPoolTests: XCTestCase {
     typealias Continuation = CancellingContinuation<Void, SocketError>
     typealias Waiting = SocketPool<MockEventQueue>.Waiting
 
-#if canImport(Darwin)
+#if canImport(Darwin) && compiler(>=5.7)
     func testKqueuePool() {
-        let pool = makeEventQueuePool()
+        let pool = SocketPool.make(maxEvents: 5)
         XCTAssertTrue(type(of: pool) == SocketPool<kQueue>.self)
     }
 #endif
 
+#if canImport(CSystemLinux) && compiler(>=5.7)
+    func testEPollPool() {
+        let pool = SocketPool.make(maxEvents: 5)
+        XCTAssertTrue(type(of: pool) == SocketPool<ePoll>.self)
+    }
+#endif
+
     func testQueuePrepare() async throws {
         let pool = SocketPool.make()