fix(DataStore): remove reconcile operations serially (#1137)

Author: lawmicha

AmplifyPlugins/DataStore/AWSDataStoreCategoryPlugin/Sync/SubscriptionSync/ReconcileAndLocalSave/ReconcileAndLocalSaveQueue.swift

@@ -71,13 +71,15 @@ class ReconcileAndSaveQueue: ReconcileAndSaveOperationQueue {
     }
 
     func addOperation(_ operation: ReconcileAndLocalSaveOperation, modelName: String) {
+
         serialQueue.async {
             var reconcileAndLocalSaveOperationSink: AnyCancellable?
-
             reconcileAndLocalSaveOperationSink = operation.publisher.sink { _ in
-                self.reconcileAndLocalSaveOperationSinks.with { $0.remove(reconcileAndLocalSaveOperationSink) }
-                self.modelReconcileAndSaveOperations[modelName]?[operation.id] = nil
-                self.reconcileAndSaveQueueSubject.send(.operationRemoved(id: operation.id))
+                self.serialQueue.async {
+                    self.reconcileAndLocalSaveOperationSinks.with { $0.remove(reconcileAndLocalSaveOperationSink) }
+                    self.modelReconcileAndSaveOperations[modelName]?[operation.id] = nil
+                    self.reconcileAndSaveQueueSubject.send(.operationRemoved(id: operation.id))
+                }
             } receiveValue: { _ in }
 
             self.reconcileAndLocalSaveOperationSinks.with { $0.insert(reconcileAndLocalSaveOperationSink) }

AmplifyPlugins/DataStore/Podfile.lock

@@ -118,4 +118,4 @@ SPEC CHECKSUMS:
 
 PODFILE CHECKSUM: 04860e414d616b67d24ed3346a60700f427764b9
 
-COCOAPODS: 1.9.3
+COCOAPODS: 1.10.1