Restrict @Loadable and @process to @mainactor

They are only ever going to be used from SwifsUI Views, so this makes the code a lot more convenient. Also, it's easy to await a Task.detached if needed

Author: SwiftedMind

Sources/Processed/Loadable/Loadable.swift

@@ -71,7 +71,7 @@ import SwiftUI
   ///
   /// It is okay to modify the state manually, instead of having it managed by a process like ``Processed/Loadable/Binding/load(silently:priority:block:)-4w49u``.
   /// However, doing so will cancel any ongoing task first, to prevent data races.
-  public var wrappedValue: LoadableState<Value> {
+  @MainActor public var wrappedValue: LoadableState<Value> {
     get { state }
     nonmutating set {
       cancel()
@@ -95,7 +95,7 @@ import SwiftUI
   ///   try await fetchNumbers()
   /// }
   /// ```
-  public var projectedValue: Binding {
+  @MainActor public var projectedValue: Binding {
     .init(state: $state, task: $task)
   }
 
@@ -210,10 +210,10 @@ extension Loadable {
     ///   The block exposes a `yield` closure you can call to continuously update the resource loading state over time.
     ///
     /// - Returns: The task that runs the asynchronous loading process. You don't have to store it, but you can.
-    @discardableResult public func load(
+    @MainActor @discardableResult public func load(
       silently runSilently: Bool = false,
       priority: TaskPriority? = nil,
-      block: @escaping (_ yield: (_ state: LoadableState<Value>) -> Void) async throws -> Void
+      block: @MainActor @escaping (_ yield: (_ state: LoadableState<Value>) -> Void) async throws -> Void
     ) -> Task<Void, Never> {
       cancel()
       setLoadingStateIfNeeded(runSilently: runSilently)
@@ -253,9 +253,9 @@ extension Loadable {
     ///   - runSilently: If `true`, the state will not be set to `.loading` initially.
     ///   - block: The asynchronous block to run.
     ///   The block exposes a `yield` closure you can call to continuously update the resource loading state over time.
-    public func load(
+    @MainActor public func load(
       silently runSilently: Bool = false,
-      block: @escaping (_ yield: (_ state: LoadableState<Value>) -> Void) async throws -> Void
+      block: @MainActor @escaping (_ yield: (_ state: LoadableState<Value>) -> Void) async throws -> Void
     ) async {
       cancel()
       setLoadingStateIfNeeded(runSilently: runSilently)
@@ -289,10 +289,10 @@ extension Loadable {
     ///   - block: The asynchronous block to run.
     ///
     /// - Returns: The task that runs the asynchronous loading process. You don't have to store it, but you can.
-    @discardableResult public func load(
+    @MainActor @discardableResult public func load(
       silently runSilently: Bool = false,
       priority: TaskPriority? = nil,
-      block: @escaping () async throws -> Value
+      block: @MainActor @escaping () async throws -> Value
     ) -> Task<Void, Never> {
       cancel()
       setLoadingStateIfNeeded(runSilently: runSilently)
@@ -311,8 +311,8 @@ extension Loadable {
       self.task = task
       return task
     }
-    
-    /// Starts a resource loading process in the current asynchronous context, 
+
+    /// Starts a resource loading process in the current asynchronous context,
     /// waiting for a return value or thrown error from the `block` closure,
     /// while setting the ``Processed/LoadableState`` accordingly.
     ///
@@ -327,9 +327,9 @@ extension Loadable {
     /// - Parameters:
     ///   - runSilently: If `true`, the state will not be set to `.loading` initially.
     ///   - block: The asynchronous block to run.
-    public func load(
+    @MainActor public func load(
       silently runSilently: Bool = false,
-      block: @escaping () async throws -> Value
+      block: @MainActor @escaping () async throws -> Value
     ) async {
       cancel()
       setLoadingStateIfNeeded(runSilently: runSilently)

Sources/Processed/Process/Process.swift

@@ -29,7 +29,7 @@ import SwiftUI
   @SwiftUI.State private var task: Task<Void, Never>?
 
   /// The current state of the process.
-  public var wrappedValue: ProcessState<ProcessID> {
+  @MainActor public var wrappedValue: ProcessState<ProcessID> {
     get { state }
     nonmutating set {
       cancel()
@@ -38,7 +38,7 @@ import SwiftUI
   }
 
   /// Provides a binding for controlling the process.
-  public var projectedValue: Binding {
+  @MainActor public var projectedValue: Binding {
     .init(state: $state, task: $task)
   }
 
@@ -66,7 +66,7 @@ extension Process {
     @SwiftUI.Binding var state: ProcessState<ProcessID>
     @SwiftUI.Binding var task: Task<Void, Never>?
 
-    public var wrappedValue: ProcessState<ProcessID> {
+    @MainActor public var wrappedValue: ProcessState<ProcessID> {
       get { state }
       nonmutating set {
         cancel()
@@ -75,7 +75,7 @@ extension Process {
     }
 
     /// Provides a binding for controlling the process.
-    public var projectedValue: Binding {
+    @MainActor public var projectedValue: Binding {
       self
     }
 
@@ -126,11 +126,11 @@ extension Process {
     ///   - priority: The priority of the task.
     ///   - block: The asynchronous block of code to execute.
     /// - Returns: The task representing the process execution.
-    @discardableResult public func run(
+    @MainActor @discardableResult public func run(
       _ process: ProcessID,
       silently runSilently: Bool = false,
       priority: TaskPriority? = nil,
-      block: @escaping () async throws -> Void
+      block: @MainActor @escaping () async throws -> Void
     ) -> Task<Void, Never> {
       cancel()
       setLoadingStateIfNeeded(runSilently: runSilently, process: process)
@@ -141,36 +141,36 @@ extension Process {
       return task
     }
 
-    public func run(
+    @MainActor public func run(
       _ process: ProcessID,
       silently runSilently: Bool = false,
-      block: @escaping () async throws -> Void
+      block: @MainActor @escaping () async throws -> Void
     ) async {
       cancel()
       setLoadingStateIfNeeded(runSilently: runSilently, process: process)
       await runTaskBody(process: process, runSilently: runSilently, block: block)
     }
 
-    public func run(
+    @MainActor public func run(
       silently runSilently: Bool = false,
-      block: @escaping () async throws -> Void
+      block: @MainActor @escaping () async throws -> Void
     ) where ProcessID == SingleProcess {
       run(.init(), silently: runSilently, block: block)
     }
 
-    public func run(
+    @MainActor public func run(
       silently runSilently: Bool = false,
-      block: @escaping () async throws -> Void
+      block: @MainActor @escaping () async throws -> Void
     ) async where ProcessID == SingleProcess {
       await run(.init(), silently: runSilently, block: block)
     }
 
     // MARK: - Internal
 
-    private func runTaskBody(
+    @MainActor private func runTaskBody(
       process: ProcessID,
       runSilently: Bool,
-      block: @escaping () async throws -> Void
+      block: @MainActor @escaping () async throws -> Void
     ) async {
       do {
         try await block()