From 3d685b9b38a40c58fdd35444d6302812df334e9a Mon Sep 17 00:00:00 2001 From: Elias Wilken Date: Thu, 26 Mar 2026 14:42:34 +0100 Subject: [PATCH] fix strict concurrency errors in blocking bridge functions --- Sources/AsyncChannels/Channel+Extensions.swift | 2 +- Sources/AsyncChannels/ThrowingChannel+Extensions.swift | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/Sources/AsyncChannels/Channel+Extensions.swift b/Sources/AsyncChannels/Channel+Extensions.swift index 2f8fa36..0cb55d6 100644 --- a/Sources/AsyncChannels/Channel+Extensions.swift +++ b/Sources/AsyncChannels/Channel+Extensions.swift @@ -31,7 +31,7 @@ extension Channel { /// Do not use this function in an async task! public func blockingReceive() -> T? { let semaphore = DispatchSemaphore(value: 0) - var val: T? + nonisolated(unsafe) var val: T? Task { val = await <-self semaphore.signal() diff --git a/Sources/AsyncChannels/ThrowingChannel+Extensions.swift b/Sources/AsyncChannels/ThrowingChannel+Extensions.swift index 2f1df40..f1bb59b 100644 --- a/Sources/AsyncChannels/ThrowingChannel+Extensions.swift +++ b/Sources/AsyncChannels/ThrowingChannel+Extensions.swift @@ -32,7 +32,7 @@ extension ThrowingChannel { /// Do not use this function in an async task! public func blockingReceive() -> T? { let semaphore = DispatchSemaphore(value: 0) - var val: T? + nonisolated(unsafe) var val: T? Task { val = await <-self semaphore.signal()