Add async/await support

Sources/Request/Request/Request.swift

@@ -106,6 +106,40 @@ public struct AnyRequest<ResponseType> where ResponseType: Decodable {
                 .subscribe(UpdateSubscriber(request: self))
         }
     }
+
+    #if swift(>=5.5)
+    /// Performs the `Request`, then returns the `ResponseType` or throws.
+    public func call() async throws -> ResponseType {
+        let publisher = self.buildPublisher()
+
+        return try await withCheckedThrowingContinuation { continuation in
+            var cancellable: AnyCancellable?
+            cancellable = publisher.sink { completion in
+                switch completion {
+                case .finished:
+                    break
+                case let .failure(error):
+                    continuation.resume(throwing: error)
+                }
+                cancellable?.cancel()
+            } receiveValue: { value in
+                do {
+                    if ResponseType.self == Data.self {
+                        continuation.resume(returning: value.data as! ResponseType)
+                    } else {
+                        continuation.resume(returning: try JSONDecoder().decode(ResponseType.self, from: value.data))
+                    }
+                } catch {
+                    continuation.resume(throwing: error)
+                }
+            }
+        }
+    }
+
+    public func callAsFunction() async throws -> ResponseType {
+        return try await call()
+    }
+    #endif
 
     internal func buildSession() -> (configuration: URLSessionConfiguration, request: URLRequest) {
         var request = URLRequest(url: URL(string: "https://")!)

Sources/Request/Request/RequestBuilder.swift

@@ -32,4 +32,8 @@ public struct RequestBuilder {
     public static func buildEither(second: RequestParam) -> RequestParam {
         second
     }
+
+    public static func buildArray(_ components: [RequestParam]) -> RequestParam {
+        CombinedParams(children: components)
+    }
 }

Sources/Request/Request/RequestParams/CombinedParams.swift

@@ -16,7 +16,7 @@ internal struct CombinedParams: RequestParam, SessionParam {
 
     func buildParam(_ request: inout URLRequest) {
         children
-            .sorted { a, _ in (a is Url) }
+            .sorted { a, _ in (a is Url) || (a is Foundation.URL) }
             .filter { !($0 is SessionParam) || $0 is CombinedParams }
             .forEach {
                 $0.buildParam(&request)

Sources/Request/Request/RequestParams/EmptyParam.swift

@@ -8,6 +8,8 @@
 import Foundation
 
 public struct EmptyParam: RequestParam {
+    public init() {}
+
     public func buildParam(_ request: inout URLRequest) {}
 }
 

Sources/Request/Request/RequestParams/Header.swift

@@ -8,7 +8,17 @@
 import Foundation
 
 /// Creates a `HeaderParam` for any number of different headers
-public struct Header {
+public struct Header: RequestParam {
+    private let _backing: `Any`
+
+    public init(key: String, value: String) {
+        self._backing = .init(key: key, value: value)
+    }
+
+    public func buildParam(_ request: inout URLRequest) {
+        _backing.buildParam(&request)
+    }
+
     /// Sets the value for any header
     public struct `Any`: RequestParam {
         private let key: String

Sources/Request/Request/RequestParams/Url/URL+RequestParam.swift

@@ -0,0 +1,7 @@
+import Foundation
+
+extension Foundation.URL: RequestParam {
+    public func buildParam(_ request: inout URLRequest) {
+        request.url = self
+    }
+}

Tests/LinuxMain.swift

@@ -1,7 +1 @@
-import XCTest
-
-import RequestTests
-
-var tests = [XCTestCaseEntry]()
-tests += RequestTests.allTests()
-XCTMain(tests)
+fatalError("Test with the `--enable-test-discovery` flag.")

Tests/RequestTests/RequestTests.swift

@@ -30,6 +30,12 @@ final class RequestTests: XCTestCase {
             Url("https://jsonplaceholder.typicode.com/todos")
         })
     }
+
+    func testFoundationURL() {
+        performRequest(Request {
+            URL(string: "https://jsonplaceholder.typicode.com/todos")!
+        })
+    }
 
     func testRequestWithCondition() {
         let condition = true
@@ -120,6 +126,16 @@ final class RequestTests: XCTestCase {
             Query([QueryParam("key", value: "value"), QueryParam("key2", value: "value2")])
         })
     }
+
+    func testBuildArray() {
+        let headers = ["Content-Type": "application/json", "Cache-Control": "no-cache"]
+        performRequest(Request {
+            Url("https://jsonplaceholder.typicode.com/todos")
+            for (key, value) in headers {
+                Header(key: key, value: value)
+            }
+        })
+    }
 
     func testComplexRequest() {
         performRequest(Request {
@@ -701,26 +717,35 @@ final class RequestTests: XCTestCase {
 
         waitForExpectations(timeout: 10000)
     }
-
-    static var allTests = [
-        ("simpleRequest", testSimpleRequest),
-        ("post", testPost),
-        ("query", testQuery),
-        ("complexRequest", testComplexRequest),
-        ("headers", testHeaders),
-        ("onObject", testObject),
-        ("onStatusCode", testStatusCode),
-        ("onString", testString),
-        ("onJson", testJson),
-        ("requestGroup", testRequestGroup),
-        ("requestChain", testRequestChain),
-        ("requestChainErrors", testRequestChainErrors),
-        ("anyRequest", testAnyRequest),
-        ("testError", testError),
-        ("testUpdate", testUpdate),
+
+    #if swift(>=5.5)
+    struct Todo: Decodable, Hashable {
+        let id: Int
+        let userId: Int
+        let title: String
+        let completed: Bool
+    }
+
+    func testAsync() async throws {
+
+        let getTodos = AnyRequest<[Todo]> {
+            Url("https://jsonplaceholder.typicode.com/todos")
+        }
+
+        // Test out `async let`, `try await`, and `callAsFunction`.
+        async let callTodos = getTodos.call()
+        async let callAsFunctionTodos = getTodos()
+        let calledTodos = try await callTodos
+        let calledAsFunctionTodos = try await callAsFunctionTodos
+        XCTAssertEqual(calledTodos, calledAsFunctionTodos)
+    }
+
+    func testCallAsFunction() async throws {
+        let request = Request {
+            Url("https://jsonplaceholder.typicode.com/todos")
+        }
 
-        ("testPublisher", testPublisher),
-        ("testPublisherDecode", testPublisherDecode),
-        ("testPublisherGroup", testPublisherGroup)
-    ]
+        let _ = try await request()
+    }
+    #endif
 }