sdfafasdfa

Author: nan-li

iOS_SDK/OneSignalSDK/OneSignalCoreMocks/MockOneSignalClient.swift

@@ -28,7 +28,8 @@ import OneSignalCore
  */
 @objc
 public class MockOneSignalClient: NSObject, IOneSignalClient {
-    public let executionQueue: DispatchQueue = DispatchQueue(label: "com.onesignal.execution", attributes: .concurrent)
+    public let executionQueue: DispatchQueue = DispatchQueue(label: "com.onesignal.execution.\(UUID().uuidString)", attributes: .concurrent)
+
     let lock = NSLock()
 
     var mockResponses: [String: [String: Any]] = [:]
@@ -45,7 +46,8 @@ public class MockOneSignalClient: NSObject, IOneSignalClient {
     var remoteParamsOutcomes: [String: Any] = [:]
 
     public var allRequestsHandled = true
-
+    var numDispatches = 0
+    
     /** May add to or change this default remote params response*/
     public func getRemoteParamsResponse() -> [String: Any] {
         return remoteParamsResponse ?? [
@@ -147,6 +149,7 @@ public class MockOneSignalClient: NSObject, IOneSignalClient {
             allRequestsHandled = false
             print("🧪 cannot find a mock response for request: \(stringifiedRequest)")
         }
+        numDispatches += 1
     }
 
     func didCompleteRequest(_ request: OneSignalRequest) {
@@ -170,6 +173,15 @@ public class MockOneSignalClient: NSObject, IOneSignalClient {
     public func setMockFailureResponseForRequest(request: String, error: NSError) {
         mockFailureResponses[request] = error
     }
+    
+    @objc
+    public func waitForRequestsToComplete() {
+        while self.numDispatches < executedRequests.count {
+            executionQueue.sync {
+                Thread.sleep(forTimeInterval: TimeInterval(1))
+            }
+        }
+    }
 }
 
 // MARK: - Asserts