LoadableViewObservable can expose elements by UUID

Author: anconaesselmann

Sources/LoadableView/Protocols/LoadableView/BaseLoadableViewModel+Refresh.swift

@@ -15,21 +15,26 @@ public extension BaseLoadableViewModel {
         refresh()
     }
 
-    func refresh(on changePublisher: AnyPublisher<Void, Never>, showLoading: Bool) -> AnyCancellable {
-        changePublisher.sink { [weak self] in
-            self?.refresh(showLoading: showLoading)
+    func refresh(on changePublisher: AnyPublisher<ObservationType, Never>, showLoading: Bool) -> AnyCancellable {
+        changePublisher.sink { [weak self] observationType in
+            switch observationType {
+            case .void:
+                self?.refresh(showLoading: showLoading)
+            case .id(let id):
+                self?._refresh(ifID: id, showLoading: showLoading)
+            }
         }
     }
 
-    func refresh(on changePublisher: AnyPublisher<Void, Never>) -> AnyCancellable {
+    func refresh(on changePublisher: AnyPublisher<ObservationType, Never>) -> AnyCancellable {
         refresh(on: changePublisher, showLoading: false)
     }
 
-    func refresh(on changePublishers: [AnyPublisher<Void, Never>], showLoading: Bool = false) -> AnyCancellable {
+    func refresh(on changePublishers: [AnyPublisher<ObservationType, Never>], showLoading: Bool = false) -> AnyCancellable {
         refresh(on: Publishers.MergeMany(changePublishers).eraseToAnyPublisher(), showLoading: showLoading)
     }
 
-    func refresh(on changePublisher: AnyPublisher<Void, Never>..., showLoading: Bool = false) -> AnyCancellable {
+    func refresh(on changePublisher: AnyPublisher<ObservationType, Never>..., showLoading: Bool = false) -> AnyCancellable {
         refresh(on: changePublisher, showLoading: showLoading)
     }
 

Sources/LoadableView/Protocols/LoadableView/BaseLoadableViewModel.swift

@@ -13,24 +13,26 @@ public protocol BaseLoadableViewModel: ObservableObject, AnyObject {
     var viewState: ViewState<Element> { get set }
     var overlayState: CurrentValueSubject<Overlay, Never> { get }
 
+    // MARK: - Optional implementation
+    func cancel() async
+
+    func onLoadingChange(isLoading: Bool)
+
+    func shouldRefresh(_ oldItem: Element?, newItem: Element) async -> Bool
+
+    func shouldAnimate(_ oldItem: Element?, newItem: Element) async -> Bool
+
     // MARK: - Don't implement
     func onAppear()
     func onDisappear()
     func setError(_ error: Error?)
     func setIsLoading(_ isLoading: Bool)
 
-    // MARK: - Don't implement
     func refresh(showLoading: Bool)
-    func refresh(on changePublisher: AnyPublisher<Void, Never>, showLoading: Bool) -> AnyCancellable
-
-    // MARK: - Optional implementation
-    func cancel() async
+    func refresh(on changePublisher: AnyPublisher<ObservationType, Never>, showLoading: Bool) -> AnyCancellable
 
-    func onLoadingChange(isLoading: Bool)
-
-    func shouldRefresh(_ oldItem: Element?, newItem: Element) async -> Bool
-    
-    func shouldAnimate(_ oldItem: Element?, newItem: Element) async -> Bool
+    // Note: - Used internally for observing LoadableViewObservables
+    func _refresh(ifID id: UUID, showLoading: Bool)
 }
 
 public extension BaseLoadableViewModel {

Sources/LoadableView/Protocols/LoadableView/IDedLoadableViewModel.swift

@@ -125,4 +125,11 @@ public extension IDedLoadableViewModel {
     func shouldAnimate(_ oldItem: Element?, newItem: Element) async -> Bool {
         return true
     }
+
+    func _refresh(ifID id: UUID, showLoading: Bool) {
+        guard self.id == id as? Self.ID else {
+            return
+        }
+        self.refresh(showLoading: showLoading)
+    }
 }

Sources/LoadableView/Protocols/LoadableView/LoadableViewModel.swift

@@ -76,4 +76,8 @@ public extension LoadableViewModel {
     func shouldAnimate(_ oldItem: Element?, newItem: Element) async -> Bool {
         return true
     }
+
+    func _refresh(ifID id: UUID, showLoading: Bool) {
+        self.refresh(showLoading: showLoading)
+    }
 }

Sources/LoadableView/Protocols/LoadableViewObservable.swift

@@ -4,8 +4,26 @@
 import Foundation
 import Combine
 
+public enum ObservationType {
+    case void, id(UUID)
+}
+
 public protocol LoadableViewObservable {
     associatedtype Change
         where Change: Hashable
-    nonisolated func publisher(for observableChange: Set<Change>) -> AnyPublisher<(), Never>
+    nonisolated func publisher(for observableChange: Set<Change>) -> AnyPublisher<ObservationType, Never>
+}
+
+public extension Publisher where Output == Void, Failure == Never {
+    var viewModelObservable: AnyPublisher<ObservationType, Never> {
+        map { .void }
+            .eraseToAnyPublisher()
+    }
+}
+
+public extension Publisher where Output == UUID, Failure == Never {
+    func viewModelObservable(_ id: UUID) -> AnyPublisher<ObservationType, Never> {
+        map { .id($0) }
+            .eraseToAnyPublisher()
+    }
 }