Structure_Concurrency5.9.0
Continuation
A mechanism to interface between synchronous code and an asynchronous stream.
- iOS
- 13.0+
- macOS
- 10.15+
- tvOS
- 13.0+
- watchOS
- 6.0+
struct ContinuationThe closure you provide to the AsyncThrowingStream in init(_:bufferingPolicy:_:) receives an instance of this type when invoked. Use this continuation to provide elements to the stream by calling one of the yield methods, then terminate the stream normally by calling the finish() method. You can also use the continuation’s finish(throwing:) method to terminate the stream by throwing an error.
Citizens in _Concurrency
Conformances
protocol SendableA type whose values can safely be passed across concurrency domains by copying.
Members
var onTermination: ((AsyncThrowingStream<Element, Failure>.Continuation.Termination) -> Void)?A callback to invoke when canceling iteration of an asynchronous stream.
func finish(throwing: Failure?) Resume the task awaiting the next iteration point by having it return nil, which signifies the end of the iteration.
func yield(Element) -> AsyncThrowingStream<Element, Failure>.Continuation.YieldResult Resume the task awaiting the next iteration point by having it return normally from its suspension point with a given element.
enum BufferingPolicyA strategy that handles exhaustion of a buffer’s capacity.
enum TerminationA type that indicates how the stream terminated.
enum YieldResultA type that indicates the result of yielding a value to a client, by way of the continuation.
Citizens in _Concurrency
where Failure:ErrorMembers
func yield() -> AsyncThrowingStream<Element, Failure>.Continuation.YieldResult Resume the task awaiting the next iteration point by having it return normally from its suspension point.
func yield(with: Result<Element, Failure>) -> AsyncThrowingStream<Element, Failure>.Continuation.YieldResult Resume the task awaiting the next iteration point by having it return normally or throw, based on a given result.