Merge branch 'release/8.3.0'

XCEssentials · Feb 17, 2024 · 696f6fb · 696f6fb
2 parents 01c7215 + c5f9dd3
commit 696f6fb
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 13 deletions.
diff --git a/Sources/XCEUniFlow/0_Helpers/Publisher+Dispatcher.swift b/Sources/XCEUniFlow/0_Helpers/Publisher+Dispatcher.swift
@@ -102,17 +102,6 @@ extension Publisher where Output == ProcessedActionReport, Failure == Never
     }
 }
 
-public
-extension Publisher where Output == StateStorage.History.Element, Failure == Never
-{
-    func `as`<T: MutationDecriptor>(
-        _: T.Type
-    ) -> AnyPublisher<T, Failure> {
-
-        compactMap(T.init(from:)).eraseToAnyPublisher()
-    }
-}
-
 // MARK: - Access log - Processed - get features statuses (dashboard)
 
 public

diff --git a/Sources/XCEUniFlow/4_Dispatcher/Dispatcher.swift b/Sources/XCEUniFlow/4_Dispatcher/Dispatcher.swift
@@ -200,7 +200,21 @@ extension Dispatcher
     /// within scope of this dispatcher.
     func on<T: MutationDecriptor>( _: T.Type) -> AnyPublisher<T, Never>
     {
-        accessLog.onProcessed.perEachMutation.as(T.self)
+        accessLog
+            .onProcessed
+            .perEachMutation
+            .compactMap(T.init(from:))
+            .eraseToAnyPublisher()
+    }
+
+    /// Designeted convenience shortcut for observing all mutations
+    /// within scope of this dispatcher.
+    @available(macOS 12.0, *)
+    func when<T: MutationDecriptor>( _: T.Type) async -> T?
+    {
+        await on(T.self) // filter for certain mutation type
+            .values
+            .first { _ in true } // no further filtering is necessary
     }
 }
 

diff --git a/Sources/XCEUniFlow/7_InternalBindings/InternalBindingBDD_WhenContext.swift b/Sources/XCEUniFlow/7_InternalBindings/InternalBindingBDD_WhenContext.swift
@@ -57,7 +57,7 @@ extension InternalBindingBDD
                 description: description,
                 when: { $0.onProcessed
                     .perEachMutation
-                    .as(M.self)
+                    .compactMap(M.init(from:))
                     .eraseToAnyPublisher()
                 }
             )