Run swift-format

(cherry picked from commit 5f37642158c326e3cad08b8e9fba7570ade625b6)

# Conflicts:
#	Tests/ComposableArchitectureTests/CompatibilityTests.swift

Author: stephencelis

Sources/ComposableArchitecture/Debugging/ReducerDebugging.swift

@@ -115,25 +115,25 @@ extension Reducer {
 
         @Sendable
         func print() {
-            debugEnvironment.queue.async {
-              var actionOutput = ""
-              if actionFormat == .prettyPrint {
-                customDump(debugAction, to: &actionOutput, indent: 2)
-              } else {
-                actionOutput.write(debugCaseOutput(debugAction).indent(by: 2))
-              }
-              let stateOutput =
-                DebugState.self == Void.self
-                ? ""
-                : diff(previousState, nextState).map { "\($0)\n" } ?? "  (No state changes)\n"
-              debugEnvironment.printer(
-                """
-                \(prefix.isEmpty ? "" : "\(prefix): ")received action:
-                \(actionOutput)
-                \(stateOutput)
-                """
-              )
+          debugEnvironment.queue.async {
+            var actionOutput = ""
+            if actionFormat == .prettyPrint {
+              customDump(debugAction, to: &actionOutput, indent: 2)
+            } else {
+              actionOutput.write(debugCaseOutput(debugAction).indent(by: 2))
             }
+            let stateOutput =
+              DebugState.self == Void.self
+              ? ""
+              : diff(previousState, nextState).map { "\($0)\n" } ?? "  (No state changes)\n"
+            debugEnvironment.printer(
+              """
+              \(prefix.isEmpty ? "" : "\(prefix): ")received action:
+              \(actionOutput)
+              \(stateOutput)
+              """
+            )
+          }
         }
 
         switch effects.operation {

Sources/ComposableArchitecture/Debugging/ReducerInstrumentation.swift

@@ -79,11 +79,13 @@
                   os_signpost(.end, log: log, name: "Effect", signpostID: sid, "%sFinished", prefix)
                 },
                 disposed: {
-                  os_signpost(.end, log: log, name: "Effect", signpostID: sid, "%sCancelled", prefix)
+                  os_signpost(
+                    .end, log: log, name: "Effect", signpostID: sid, "%sCancelled", prefix)
                 },
                 value: { value in
                   os_signpost(
-                    .event, log: log, name: "Effect Output", "%sOutput from %s", prefix, actionOutput
+                    .event, log: log, name: "Effect Output", "%sOutput from %s", prefix,
+                    actionOutput
                   )
                 }
               )

Sources/ComposableArchitecture/Effect.swift

@@ -158,7 +158,7 @@ extension Effect where Failure == Never {
         }
       }
     )
-    }
+  }
 
   /// Wraps an asynchronous unit of work that can emit any number of times in an effect.
   ///
@@ -368,7 +368,7 @@ extension Effect {
     case (.none, _):
       return other
     case (.producer, .producer), (.run, .producer), (.producer, .run):
-        return Self(operation: .producer(.merge(self.producer, other.producer)))
+      return Self(operation: .producer(.merge(self.producer, other.producer)))
     case let (.run(lhsPriority, lhsOperation), .run(rhsPriority, rhsOperation)):
       return Self(
         operation: .run { send in
@@ -422,7 +422,7 @@ extension Effect {
     case (.producer, .producer), (.run, .producer), (.producer, .run):
       return Self(
         operation: .producer(
-            SignalProducer.concatenate(self.producer, other.producer)
+          SignalProducer.concatenate(self.producer, other.producer)
         )
       )
     case let (.run(lhsPriority, lhsOperation), .run(rhsPriority, rhsOperation)):

Sources/ComposableArchitecture/Effects/Cancellation.swift

@@ -58,7 +58,7 @@ extension Effect {
             let values = Atomic<[Output]>([])
             var isCaching = true
             let disposable =
-            producer
+              producer
               .on(value: { value in
                 guard isCaching else { return }
                 values.modify { $0.append(value) }

Sources/ComposableArchitecture/Effects/SignalProducer.swift

@@ -60,7 +60,8 @@ extension Effect {
     watchOS, deprecated: 9999.0,
     message: "Iterate over 'SignalProducer.values' in an 'Effect.run', instead."
   )
-  public init<P: SignalProducerConvertible>(_ producer: P) where P.Value == Output, P.Error == Failure {
+  public init<P: SignalProducerConvertible>(_ producer: P)
+  where P.Value == Output, P.Error == Failure {
     self.operation = .producer(producer.producer)
   }
 
@@ -525,7 +526,7 @@ extension SignalProducer {
     outputType: NewValue.Type = NewValue.self,
     failureType: NewError.Type = NewError.self
   ) -> Effect<NewValue, NewError> {
-      self
+    self
       .flatMapError { _ in .empty }
       .flatMap(.latest) { _ in .empty }
       .eraseToEffect()

Sources/ComposableArchitecture/Effects/Throttling.swift

@@ -51,7 +51,7 @@ extension Effect {
           return SignalProducer(value: value)
             .delay(
               throttleTime.addingTimeInterval(interval).timeIntervalSince1970
-              - scheduler.currentDate.timeIntervalSince1970,
+                - scheduler.currentDate.timeIntervalSince1970,
               on: scheduler
             ).on(
               value: { _ in

Sources/ComposableArchitecture/Internal/Deprecations.swift

@@ -460,7 +460,7 @@ extension Effect where Failure == Error {
             observer.send(error: error)
         }
       }
-      }
+    }
 
       return producer.on(disposed: task?.cancel)
     }

Sources/ComposableArchitecture/Internal/TaskCancellableValue.swift

@@ -1,26 +1,26 @@
 #if canImport(_Concurrency) && compiler(>=5.5.2)
-extension Task where Failure == Error {
-  var cancellableValue: Success {
-    get async throws {
-      try await withTaskCancellationHandler {
-        self.cancel()
-      } operation: {
-        try await self.value
+  extension Task where Failure == Error {
+    var cancellableValue: Success {
+      get async throws {
+        try await withTaskCancellationHandler {
+          self.cancel()
+        } operation: {
+          try await self.value
+        }
       }
     }
   }
-}
 
-extension Task where Failure == Never {
-  @usableFromInline
-  var cancellableValue: Success {
-    get async {
-      await withTaskCancellationHandler {
-        self.cancel()
-      } operation: {
-        await self.value
+  extension Task where Failure == Never {
+    @usableFromInline
+    var cancellableValue: Success {
+      get async {
+        await withTaskCancellationHandler {
+          self.cancel()
+        } operation: {
+          await self.value
+        }
       }
     }
   }
-}
 #endif

Sources/ComposableArchitecture/Store.swift

@@ -374,24 +374,24 @@ public final class Store<State, Action> {
             }
           },
           completed: { [weak self] in
-              self?.threadCheck(status: .effectCompletion(action))
-              boxedTask.wrappedValue?.cancel()
-              didComplete = true
+            self?.threadCheck(status: .effectCompletion(action))
+            boxedTask.wrappedValue?.cancel()
+            didComplete = true
             self?.effectDisposables.removeValue(forKey: uuid)?.dispose()
-            },
+          },
           interrupted: { [weak self] in
             boxedTask.wrappedValue?.cancel()
             didComplete = true
             self?.effectDisposables.removeValue(forKey: uuid)?.dispose()
-              }
+          }
         )
 
         let effectDisposable = CompositeDisposable()
         effectDisposable += producer.start(observer)
         effectDisposable += AnyDisposable { [weak self] in
           self?.threadCheck(status: .effectCompletion(action))
           self?.effectDisposables.removeValue(forKey: uuid)?.dispose()
-            }
+        }
 
         if !didComplete {
           let task = Task<Void, Never> { @MainActor in