Skip to content

Make MultiProducerSingleConsumerAsyncChannel internals compatible with library evolution #426

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
adityasingh2400 wants to merge 1 commit into from
Closed

Make MultiProducerSingleConsumerAsyncChannel internals compatible with library evolution #426

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions Sources/AsyncAlgorithms/Internal/_TinyArray.swift
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -26,8 +26,10 @@
/// It supports arbitrary many elements but if only up to one ``Element`` is stored it does **not** allocate separate storage on the heap
/// and instead stores the ``Element`` inline.
@usableFromInline
@frozen
struct _TinyArray<Element> {
@usableFromInline
@frozen
enum Storage {
case one(Element)
case arbitrary([Element])
Expand Down
13 changes: 12 additions & 1 deletion ...MultiProducerSingleConsumerChannel/MultiProducerSingleConsumerAsyncChannel+Internal.swift
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,8 +16,10 @@ import Synchronization
@available(AsyncAlgorithms 1.1, *)
extension MultiProducerSingleConsumerAsyncChannel {
@usableFromInline
@frozen
enum _InternalBackpressureStrategy: Sendable, CustomStringConvertible {
@usableFromInline
@frozen
struct _Watermark: Sendable, CustomStringConvertible {
/// The low watermark where demand should start.
@usableFromInline
Expand Down Expand Up @@ -118,7 +120,7 @@ extension MultiProducerSingleConsumerAsyncChannel {
@usableFromInline
let _stateMachine: Mutex<_StateMachine>

@inlinable
@usableFromInline
init(
backpressureStrategy: _InternalBackpressureStrategy
) {
Expand Down Expand Up @@ -505,6 +507,7 @@ extension MultiProducerSingleConsumerAsyncChannel {
extension MultiProducerSingleConsumerAsyncChannel._Storage {
/// The state machine of the channel.
@usableFromInline
@frozen
struct _StateMachine: ~Copyable {
/// The state machine's current state.
@usableFromInline
Expand Down Expand Up @@ -1358,6 +1361,7 @@ extension MultiProducerSingleConsumerAsyncChannel._Storage {
/// destructively pattern-matching an enum case with multiple payloads
/// that include a `~Copyable` generic wrapper type (`Disconnected`).
@usableFromInline
@frozen
struct ResumeElement: ~Copyable, Sendable {
@usableFromInline let continuation: UnsafeContinuation<Element?, Error>
@usableFromInline var element: Disconnected<Element>
Expand All @@ -1375,6 +1379,7 @@ extension MultiProducerSingleConsumerAsyncChannel._Storage {
///
/// - Note: See `ResumeElement` for the reason behind this wrapper.
@usableFromInline
@frozen
struct ResumeElementAndProducers: ~Copyable, Sendable {
@usableFromInline let continuation: UnsafeContinuation<Element?, Error>
@usableFromInline var element: Disconnected<Element>
Expand All @@ -1395,6 +1400,7 @@ extension MultiProducerSingleConsumerAsyncChannel._Storage {
///
/// - Note: See `ResumeElement` for the reason behind this wrapper.
@usableFromInline
@frozen
struct ResumeFailure: ~Copyable, Sendable {
@usableFromInline let continuation: UnsafeContinuation<Element?, Error>
@usableFromInline let failure: Failure?
Expand Down Expand Up @@ -1560,8 +1566,10 @@ extension MultiProducerSingleConsumerAsyncChannel._Storage {
@available(macOS 15.0, iOS 18.0, watchOS 11.0, tvOS 18.0, visionOS 2.0, *)
extension MultiProducerSingleConsumerAsyncChannel._Storage._StateMachine {
@usableFromInline
@frozen
enum _State: ~Copyable {
@usableFromInline
@frozen
struct Channeling: ~Copyable {
/// The backpressure strategy.
@usableFromInline
Expand Down Expand Up @@ -1662,6 +1670,7 @@ extension MultiProducerSingleConsumerAsyncChannel._Storage._StateMachine {
}

@usableFromInline
@frozen
struct SourceFinished: ~Copyable {
/// Indicates if the iterator was initialized.
@usableFromInline
Expand Down Expand Up @@ -1718,6 +1727,7 @@ extension MultiProducerSingleConsumerAsyncChannel._Storage._StateMachine {
}

@usableFromInline
@frozen
struct Finished: ~Copyable {
/// Indicates if the iterator was initialized.
@usableFromInline
Expand Down Expand Up @@ -1783,6 +1793,7 @@ enum _MultiProducerSingleConsumerSuspendedProducer: @unchecked Sendable {

// TODO: This should be replaced with Disconnected once we have a UniqueDeque
@usableFromInline
@frozen
struct SendableConsumeOnceBox<Wrapped> {
@usableFromInline
var wrapped: Optional<Wrapped>
Expand Down