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()