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