fix(datastore): memory leak in ModelSyncedEventEmitter (#3675)

* fix(datastore): memory leak in ModelSyncedEventEmitter * resolve lint comments
aws-amplify · May 7, 2024 · cd5545b · cd5545b
1 parent dd64b90
commit cd5545b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ugins/DataStore/Sources/AWSDataStorePlugin/Sync/InitialSync/ModelSyncedEventEmitter.swift b/...ugins/DataStore/Sources/AWSDataStorePlugin/Sync/InitialSync/ModelSyncedEventEmitter.swift
@@ -65,7 +65,7 @@ final class ModelSyncedEventEmitter {
         self.syncOrchestratorSink = initialSyncOrchestrator?
             .publisher
             .receive(on: queue)
-            .filter(filterSyncOperationEvent(_:))
+            .filter { [weak self] in self?.filterSyncOperationEvent($0) == true }
             .sink(receiveCompletion: { _ in },
                   receiveValue: { [weak self] value in
                     self?.onReceiveSyncOperationEvent(value: value)
@@ -74,7 +74,7 @@ final class ModelSyncedEventEmitter {
         self.reconciliationQueueSink = reconciliationQueue?
             .publisher
             .receive(on: queue)
-            .filter(filterReconciliationQueueEvent(_:))
+            .filter { [weak self] in self?.filterReconciliationQueueEvent($0) == true }
             .sink(receiveCompletion: { _ in },
                   receiveValue: { [weak self] value in
                     self?.onReceiveReconciliationEvent(value: value)