Merge pull request #8 from arunrd/change-scheduler

Use DispatchQueue scheduler
freshOS · Oct 27, 2020 · b18883b · b18883b
2 parents f37e76a + 2424854
commit b18883b
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 9 deletions.
diff --git 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<T, Error> {
         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<T, Error> {
         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<T, Error> {
         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<T, Error> {
         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<T, Error> {
         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
@@ -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<Data, Error> {
@@ -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
@@ -89,7 +89,7 @@ public extension NetworkingService {
                                          keypath: String? = nil) -> AnyPublisher<T, Error> {
         return get(route, params: params)
             .tryMap { json -> T in try NetworkingParser().toModel(json, keypath: keypath) }
-            .receive(on: RunLoop.main)
+            .receive(on: DispatchQueue.main)
             .eraseToAnyPublisher()
     }