AsyncValueObservation is Sendable

A Sendable async sequences plays well with apple/swift-async-algorithms
groue · Sep 28, 2024 · 820f0a1 · 820f0a1
1 parent 972aa33
commit 820f0a1
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/GRDB/ValueObservation/ValueObservation.swift b/GRDB/ValueObservation/ValueObservation.swift
@@ -384,11 +384,13 @@ extension ValueObservation {
 ///
 /// You build an `AsyncValueObservation` from ``ValueObservation`` or
 /// ``SharedValueObservation``.
-public struct AsyncValueObservation<Element: Sendable>: AsyncSequence {
+public struct AsyncValueObservation<Element: Sendable>: AsyncSequence, Sendable {
     public typealias BufferingPolicy = AsyncThrowingStream<Element, Error>.Continuation.BufferingPolicy
     public typealias AsyncIterator = Iterator
 
-    var bufferingPolicy: BufferingPolicy
+    // AsyncThrowingStream.Continuation.BufferingPolicy is obviously
+    // Sendable, but lacks Sendable conformance.
+    nonisolated(unsafe) var bufferingPolicy: BufferingPolicy
     var start: ValueObservationStart<Element>
 
     public func makeAsyncIterator() -> Iterator {