diff --git a/Sources/Networking/Calls/NetworkingClient+NetworkingJSONDecodable.swift b/Sources/Networking/Calls/NetworkingClient+NetworkingJSONDecodable.swift index cec4a38..f8c384b 100644 --- a/Sources/Networking/Calls/NetworkingClient+NetworkingJSONDecodable.swift +++ b/Sources/Networking/Calls/NetworkingClient+NetworkingJSONDecodable.swift @@ -20,7 +20,7 @@ public extension NetworkingClient { keypath: String? = nil) -> AnyPublisher { return get(route, params: params) .tryMap { json -> T in try NetworkingParser().toModel(json, keypath: keypath) } - .receive(on: RunLoop.main) + .receive(on: DispatchQueue.main) .eraseToAnyPublisher() } @@ -31,7 +31,7 @@ public extension NetworkingClient { let keypath = keypath ?? defaultCollectionParsingKeyPath return get(route, params: params) .map { json -> [T] in NetworkingParser().toModels(json, keypath: keypath) } - .receive(on: RunLoop.main) + .receive(on: DispatchQueue.main) .eraseToAnyPublisher() } @@ -40,7 +40,7 @@ public extension NetworkingClient { keypath: String? = nil) -> AnyPublisher { return post(route, params: params) .tryMap { json -> T in try NetworkingParser().toModel(json, keypath: keypath) } - .receive(on: RunLoop.main) + .receive(on: DispatchQueue.main) .eraseToAnyPublisher() } @@ -49,7 +49,7 @@ public extension NetworkingClient { keypath: String? = nil) -> AnyPublisher { return put(route, params: params) .tryMap { json -> T in try NetworkingParser().toModel(json, keypath: keypath) } - .receive(on: RunLoop.main) + .receive(on: DispatchQueue.main) .eraseToAnyPublisher() } @@ -58,7 +58,7 @@ public extension NetworkingClient { keypath: String? = nil) -> AnyPublisher { return patch(route, params: params) .tryMap { json -> T in try NetworkingParser().toModel(json, keypath: keypath) } - .receive(on: RunLoop.main) + .receive(on: DispatchQueue.main) .eraseToAnyPublisher() } @@ -67,7 +67,7 @@ public extension NetworkingClient { keypath: String? = nil) -> AnyPublisher { return delete(route, params: params) .tryMap { json -> T in try NetworkingParser().toModel(json, keypath: keypath) } - .receive(on: RunLoop.main) + .receive(on: DispatchQueue.main) .eraseToAnyPublisher() } } diff --git a/Sources/Networking/NetworkingRequest.swift b/Sources/Networking/NetworkingRequest.swift index dc3c2d8..6615155 100644 --- a/Sources/Networking/NetworkingRequest.swift +++ b/Sources/Networking/NetworkingRequest.swift @@ -64,7 +64,7 @@ public class NetworkingRequest: NSObject { }.eraseToAnyPublisher() return Publishers.Merge(callPublisher, progressPublisher2) - .receive(on: RunLoop.main).eraseToAnyPublisher() + .receive(on: DispatchQueue.main).eraseToAnyPublisher() } public func publisher() -> AnyPublisher { @@ -96,7 +96,7 @@ public class NetworkingRequest: NSObject { } else { return NetworkingError.unableToParseResponse } - }.receive(on: RunLoop.main).eraseToAnyPublisher() + }.receive(on: DispatchQueue.main).eraseToAnyPublisher() } private func getURLWithParams() -> String { diff --git a/Sources/Networking/NetworkingService.swift b/Sources/Networking/NetworkingService.swift index 488eb9d..8a4eeb9 100644 --- a/Sources/Networking/NetworkingService.swift +++ b/Sources/Networking/NetworkingService.swift @@ -89,7 +89,7 @@ public extension NetworkingService { keypath: String? = nil) -> AnyPublisher { return get(route, params: params) .tryMap { json -> T in try NetworkingParser().toModel(json, keypath: keypath) } - .receive(on: RunLoop.main) + .receive(on: DispatchQueue.main) .eraseToAnyPublisher() }