[feat] Concurrency improvements

Tests/NetworkingTests/APIManagerTests.swift

@@ -50,7 +50,7 @@ final class APIManagerTests: XCTestCase {
             responseProcessors: []
         )
 
-        // Create 15 parallel requests on multiple threads to test the managers thread safety.
+        // Create 15 parallel requests on multiple threads to test the manager's thread safety.
         try await withThrowingTaskGroup(of: Void.self) { group in
             for _ in 0..<15 {
                 group.addTask {

Tests/NetworkingTests/DownloadAPIManagerTests.swift

@@ -0,0 +1,59 @@
+//
+//  File.swift
+//
+//
+//  Created by Matej Molnár on 01.01.2024.
+//
+
+@testable import Networking
+import XCTest
+
+@NetworkingActor
+final class DownloadAPIManagerTests: XCTestCase {
+    enum DownloadRouter: Requestable {
+        case download(url: URL)
+
+        var baseURL: URL {
+            switch self {
+            case let .download(url):
+                url
+            }
+        }
+
+        var path: String {
+            switch self {
+            case .download:
+                ""
+            }
+        }
+    }
+
+    func testMultiThreadRequests() async throws {
+        let apiManager = DownloadAPIManager(
+            // A session configuration that uses no persistent storage for caches, cookies, or credentials.
+            urlSessionConfiguration: .ephemeral,
+            // Set empty response processors since the mock download requests return status code 0 and we don't want the test fail.
+            responseProcessors: []
+        )
+
+        // We can simulate the download even with a local file.
+        guard let downloadUrl = Bundle.module.url(forResource: "download_test", withExtension: "txt") else {
+            XCTFail("Resource not found")
+            return
+        }
+
+        // Create 15 parallel requests on multiple threads to test the manager's thread safety.
+        try await withThrowingTaskGroup(of: Void.self) { group in
+            for _ in 0..<15 {
+                group.addTask {
+                    _ = try await apiManager.downloadRequest(
+                        DownloadRouter.download(url: downloadUrl),
+                        retryConfiguration: nil
+                    )
+                }
+            }
+
+            try await group.waitForAll()
+        }
+    }
+}

Tests/NetworkingTests/Resources/download_test.txt

@@ -0,0 +1 @@
+just a test download file

Tests/NetworkingTests/UploadAPIManagerTests.swift

@@ -0,0 +1,48 @@
+//
+//  File.swift
+//
+//
+//  Created by Matej Molnár on 01.01.2024.
+//
+
+@testable import Networking
+import XCTest
+
+@NetworkingActor
+final class UploadAPIManagerTests: XCTestCase {
+    enum UploadRouter: Requestable {
+        case mock
+
+        var baseURL: URL {
+            // swiftlint:disable:next force_unwrapping
+            URL(string: "https://uploadAPIManager.tests")!
+        }
+
+        var path: String {
+            "/mock"
+        }
+
+        var method: HTTPMethod {
+            .post
+        }
+    }
+
+    func testMultiThreadRequests2() async throws {
+        let apiManager = UploadAPIManager(
+            // A session configuration that uses no persistent storage for caches, cookies, or credentials.
+            urlSessionConfiguration: .ephemeral
+        )
+        let data = Data("Test data".utf8)
+
+        // Create 15 parallel requests on multiple threads to test the manager's thread safety.
+        try await withThrowingTaskGroup(of: Void.self) { group in
+            for _ in 0..<15 {
+                group.addTask {
+                    _ = try await apiManager.upload(data: data, to: UploadRouter.mock)
+                }
+            }
+
+            try await group.waitForAll()
+        }
+    }
+}