diff --git a/Sources/RecombinePackage/Store/BaseStore.swift b/Sources/RecombinePackage/Store/BaseStore.swift index abcc6f9..40d8563 100644 --- a/Sources/RecombinePackage/Store/BaseStore.swift +++ b/Sources/RecombinePackage/Store/BaseStore.swift @@ -200,6 +200,7 @@ public class BaseStore: StoreProtoco } // Cancel if dispatch is manually reenabled. .prefix(untilOutputFrom: $dispatchEnabled.filter { $0 }) + .receive(on: DispatchQueue.main) .sink( receiveCompletion: { _ in self.dispatchEnabled = true