diff --git a/Sources/Concurrency/Executor/ConcurrentSequenceExecutor.swift b/Sources/Concurrency/Executor/ConcurrentSequenceExecutor.swift index 2517174..d3fb18b 100644 --- a/Sources/Concurrency/Executor/ConcurrentSequenceExecutor.swift +++ b/Sources/Concurrency/Executor/ConcurrentSequenceExecutor.swift @@ -72,10 +72,8 @@ public class ConcurrentSequenceExecutor: SequenceExecutor { private func execute(_ task: Task, with sequenceHandle: SynchronizedSequenceExecutionHandle, _ execution: @escaping (Task, Any) -> SequenceExecution) { taskSemaphore?.wait() taskQueue.async { - if let taskSemaphore = self.taskSemaphore { - defer { - taskSemaphore.signal() - } + defer { + self.taskSemaphore?.signal() } guard !sequenceHandle.isCancelled else {