View on GitHub
InternalTaskAsyncSequenceContext
public struct InternalTaskAsyncSequenceContext<InProcess> where InProcess : Sendable-
Declaration
Swift
public let bufferingPolicy: AsyncStream<InProcess>.Continuation.BufferingPolicy -
Declaration
Swift
public var weakSequenceRef: WeakAmplifyAsyncSequenceRef<InProcess> -
Declaration
Swift
public var task: Task<Void, Error>? -
Declaration
Swift
public var sequence: AmplifyAsyncSequence<InProcess>? { get set } -
Declaration
Swift
public init(bufferingPolicy: AsyncStream<InProcess>.Continuation.BufferingPolicy = .unbounded)