Skip to content

Make AsyncShareSequence Type Public #412

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

Open
AGiersch1804 wants to merge 1 commit into
base: main
Choose a base branch
from
+8 −8
Open

Make AsyncShareSequence Type Public #412

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
16 changes: 8 additions & 8 deletions Sources/AsyncAlgorithms/AsyncShareSequence.swift
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ where Element: Sendable, Self: SendableMetatype, AsyncIterator: SendableMetatype
///
public func share(
bufferingPolicy: AsyncBufferSequencePolicy = .bounded(1)
) -> some AsyncSequence<Element, Failure> & Sendable {
) -> AsyncShareSequence<Self> {
// The iterator is transferred to the isolation of the iterating task
// this has to be done "unsafely" since we cannot annotate the transfer
// however since iterating an AsyncSequence types twice has been defined
Expand Down Expand Up @@ -115,7 +115,7 @@ where Element: Sendable, Self: SendableMetatype, AsyncIterator: SendableMetatype
// This type is typically not used directly; instead, use the `share()` method on any
// async sequence that meets the sendability requirements.
@available(AsyncAlgorithms 1.1, *)
struct AsyncShareSequence<Base: AsyncSequence>: Sendable
public struct AsyncShareSequence<Base: AsyncSequence>: Sendable
where Base.Element: Sendable, Base: SendableMetatype, Base.AsyncIterator: SendableMetatype {
// Represents a single consumer's connection to the shared sequence.
//
Expand Down Expand Up @@ -699,26 +699,26 @@ where Base.Element: Sendable, Base: SendableMetatype, Base.AsyncIterator: Sendab

@available(AsyncAlgorithms 1.1, *)
extension AsyncShareSequence: AsyncSequence {
typealias Element = Base.Element
typealias Failure = Base.Failure
public typealias Element = Base.Element
public typealias Failure = Base.Failure

struct Iterator: AsyncIteratorProtocol {
public struct Iterator: AsyncIteratorProtocol {
let side: Side

init(_ iteration: Iteration) {
side = Side(iteration)
}

mutating func next() async rethrows -> Element? {
public mutating func next() async rethrows -> Element? {
try await side.next(isolation: nil)
}

mutating func next(isolation actor: isolated (any Actor)?) async throws(Failure) -> Element? {
public mutating func next(isolation actor: isolated (any Actor)?) async throws(Failure) -> Element? {
try await side.next(isolation: actor)
}
}

func makeAsyncIterator() -> Iterator {
public func makeAsyncIterator() -> Iterator {
Iterator(extent.iteration)
}
}
Expand Down