diff --git a/Sources/AsyncSequenceValidation/Clock.swift b/Sources/AsyncSequenceValidation/Clock.swift index 492e0bbc..c85c92c1 100644 --- a/Sources/AsyncSequenceValidation/Clock.swift +++ b/Sources/AsyncSequenceValidation/Clock.swift @@ -22,6 +22,7 @@ extension AsyncSequenceValidationDiagram { } } +@available(AsyncAlgorithms 1.0, *) public protocol TestClock: Sendable { associatedtype Instant: TestInstant @@ -30,6 +31,7 @@ public protocol TestClock: Sendable { func sleep(until deadline: Self.Instant, tolerance: Self.Instant.Duration?) async throws } +@available(AsyncAlgorithms 1.0, *) public protocol TestInstant: Equatable { associatedtype Duration } diff --git a/Tests/AsyncAlgorithmsTests/MultiProducerSingleConsumerChannel/MultiProducerSingleConsumerAsyncChannelTests.swift b/Tests/AsyncAlgorithmsTests/MultiProducerSingleConsumerChannel/MultiProducerSingleConsumerAsyncChannelTests.swift index ead13dee..d57dfbf6 100644 --- a/Tests/AsyncAlgorithmsTests/MultiProducerSingleConsumerChannel/MultiProducerSingleConsumerAsyncChannelTests.swift +++ b/Tests/AsyncAlgorithmsTests/MultiProducerSingleConsumerChannel/MultiProducerSingleConsumerAsyncChannelTests.swift @@ -971,7 +971,7 @@ final class MultiProducerSingleConsumerAsyncChannelTests: XCTestCase { backpressureStrategy: .watermark(low: 2, high: 4) ) let channel = channelAndSource.takeChannel() - var source: MultiProducerSingleConsumerAsyncChannel.Source! = consume channelAndSource.source + var source: MultiProducerSingleConsumerAsyncChannel.Source! = consume channelAndSource.source group.addTask { var source = source.take()!