File tree 1 file changed +2
-2
lines changed
AmplifyPlugins/DataStore/Sources/AWSDataStorePlugin/Sync/InitialSync
1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -65,7 +65,7 @@ final class ModelSyncedEventEmitter {
65
65
self . syncOrchestratorSink = initialSyncOrchestrator?
66
66
. publisher
67
67
. receive ( on: queue)
68
- . filter ( filterSyncOperationEvent ( _ : ) )
68
+ . filter { [ weak self ] in self ? . filterSyncOperationEvent ( $0 ) == true }
69
69
. sink ( receiveCompletion: { _ in } ,
70
70
receiveValue: { [ weak self] value in
71
71
self ? . onReceiveSyncOperationEvent ( value: value)
@@ -74,7 +74,7 @@ final class ModelSyncedEventEmitter {
74
74
self . reconciliationQueueSink = reconciliationQueue?
75
75
. publisher
76
76
. receive ( on: queue)
77
- . filter ( filterReconciliationQueueEvent ( _ : ) )
77
+ . filter { [ weak self ] in self ? . filterReconciliationQueueEvent ( $0 ) == true }
78
78
. sink ( receiveCompletion: { _ in } ,
79
79
receiveValue: { [ weak self] value in
80
80
self ? . onReceiveReconciliationEvent ( value: value)
You can’t perform that action at this time.
0 commit comments