Merge branch 'main' into ff-poolmanager

fabianfett · web-flow · commit 3dc6c2f5e781 · 2025-09-18T12:03:26.000+02:00
diff --git a/Sources/ConnectionPoolModule/ConnectionPool.swift b/Sources/ConnectionPoolModule/ConnectionPool.swift
@@ -310,12 +310,15 @@ public final class ConnectionPool<
                 await self.run(in: &taskGroup)
             }
         } onCancel: {
-            let actions = self.stateBox.withLockedValue { state in
-                state.stateMachine.triggerForceShutdown()
-            }
+            self.triggerForceShutdown()
+        }
+    }
 
-            self.runStateMachineActions(actions)
+    public func triggerForceShutdown() {
+        let actions = self.stateBox.withLockedValue { state in
+            state.stateMachine.triggerForceShutdown()
         }
+        self.runStateMachineActions(actions)
     }
 
     // MARK: - Private Methods -

Original file line number	Diff line number	Diff line change
`@@ -310,12 +310,15 @@ public final class ConnectionPool<`
`310`	`310`	`await self.run(in: &taskGroup)`
`311`	`311`	`}`
`312`	`312`	`} onCancel: {`
`313`		`- let actions = self.stateBox.withLockedValue { state in`
`314`		`- state.stateMachine.triggerForceShutdown()`
`315`		`- }`
	`313`	`+ self.triggerForceShutdown()`
	`314`	`+ }`
	`315`	`+ }`
`316`	`316`
`317`		`- self.runStateMachineActions(actions)`
	`317`	`+ public func triggerForceShutdown() {`
	`318`	`+ let actions = self.stateBox.withLockedValue { state in`
	`319`	`+ state.stateMachine.triggerForceShutdown()`
`318`	`320`	`}`
	`321`	`+ self.runStateMachineActions(actions)`
`319`	`322`	`}`
`320`	`323`
`321`	`324`	`// MARK: - Private Methods -`