a

swhitty · Oct 30, 2024 · a1bb9a2 · a1bb9a2
1 parent 0482ba5
commit a1bb9a2
Showing 1 changed file with 40 additions and 38 deletions.
diff --git a/FlyingFox/Sources/URLSession+Async.swift b/FlyingFox/Sources/URLSession+Async.swift
@@ -32,41 +32,43 @@
 import Foundation
 import FlyingSocks
 
-#if canImport(FoundationNetworking)
-import FoundationNetworking
-
-extension URLSession {
-
-    // Ports macOS Foundation method to Linux
-    func data(for request: URLRequest) async throws -> (Data, URLResponse) {
-        let state = Mutex((isCancelled: false, task: URLSessionDataTask?.none))
-        return try await withTaskCancellationHandler {
-            try await withCheckedThrowingContinuation { continuation in
-                let task = dataTask(with: request) { data, response, error in
-                    guard let data = data, let response = response else {
-                        continuation.resume(throwing: error!)
-                        return
-                    }
-                    continuation.resume(returning: (data, response))
-                }
-                let shouldCancel = state.withLock {
-                    $0.task = task
-                    return $0.isCancelled
-                }
-                task.resume()
-                if shouldCancel {
-                    task.cancel()
-                }
-            }
-        } onCancel: {
-            let taskToCancel = state.withLock {
-                $0.isCancelled = true
-                return $0.task
-            }
-            if let taskToCancel {
-                taskToCancel.cancel()
-            }
-        }
-    }
-}
-#endif
+//#if canImport(FoundationNetworking)
+//import FoundationNetworking
+//
+//extension URLSession {
+//
+//    // Ports macOS Foundation method to Linux
+//    func data(for request: URLRequest) async throws -> (Data, URLResponse) {
+//
+//
+//        let state = Mutex((isCancelled: false, task: URLSessionDataTask?.none))
+//        return try await withTaskCancellationHandler {
+//            try await withCheckedThrowingContinuation { continuation in
+//                let task = dataTask(with: request) { data, response, error in
+//                    guard let data = data, let response = response else {
+//                        continuation.resume(throwing: error!)
+//                        return
+//                    }
+//                    continuation.resume(returning: (data, response))
+//                }
+//                let shouldCancel = state.withLock {
+//                    $0.task = task
+//                    return $0.isCancelled
+//                }
+//                task.resume()
+//                if shouldCancel {
+//                    task.cancel()
+//                }
+//            }
+//        } onCancel: {
+//            let taskToCancel = state.withLock {
+//                $0.isCancelled = true
+//                return $0.task
+//            }
+//            if let taskToCancel {
+//                taskToCancel.cancel()
+//            }
+//        }
+//    }
+//}
+//#endif