aparoksha/meta
1
1
Fork 0
Code Issues Pull Requests Actions Releases 1 Activity

Adapt blocking updates to strict concurrency

Browse Source
This commit is contained in:
david-swift 2024-09-29 19:05:29 +02:00
parent ebb68009ee
commit 9a3760b24c
3 changed files with 31 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
Sources/Model/Data Flow/Model.swift
View File

@ -85,7 +85,9 @@ extension Model {
setModel(&model)
data.storage.value = model
data.storage.update = true
StateManager.updateViews(force: data.force)
Task {
await StateManager.updateViews(force: data.force)
}
}
/// Get the current version of the model.
@ -114,7 +116,9 @@ extension Model where Self: Sendable {
}
data.storage.value = newValue
data.storage.update = true
StateManager.updateViews(force: data.force)
Task {
await StateManager.updateViews(force: data.force)
}
}
}

4
Sources/Model/Data Flow/State.swift
View File

@ -19,7 +19,9 @@ public struct State<Value>: StateProtocol, Sendable where Value: Sendable {
nonmutating set {
rawValue = newValue
content.update = true
StateManager.updateViews(force: forceUpdates)
Task {
await StateManager.updateViews(force: forceUpdates)
}
}
}

25
Sources/Model/Data Flow/StateManager.swift
View File

@ -8,21 +8,24 @@
import Foundation
/// This type manages view updates.
@globalActor
public actor StateManager {
/// Whether to block updates in general.
public static var blockUpdates = false
@StateManager static var blockAllUpdates = false
/// The application identifier.
static var appID: String?
/// The functions handling view updates.
static var updateHandlers: [@Sendable (Bool) async -> Void] = []
/// The shared instance of the actor.
public static let shared = StateManager()
/// Update all of the views.
/// - Parameter force: Whether to force all views to update.
///
/// Nothing happens if ``StateManager/blockUpdates`` is true.
public static func updateViews(force: Bool = false) {
if !blockUpdates {
public static func updateViews(force: Bool = false) async {
if await !blockAllUpdates {
for handler in updateHandlers {
Task {
await handler(force)
@ -37,4 +40,20 @@ public actor StateManager {
updateHandlers.append(handler)
}
/// Block all updates.
///
/// The user interface will not respond to changes.
@StateManager
public static func blockUpdates() {
blockAllUpdates = true
}
/// Unblock all updates.
///
/// The user interface will respond to changes.
@StateManager
public static func unblockUpdates() {
blockAllUpdates = false
}
}