makeStream(of:bufferingPolicy:)
Initializes a new AsyncStream
and an Continuation
.
- iOS
- 13.0+
- macOS
- 10.15+
- tvOS
- 13.0+
- watchOS
- 6.0+
@backDeployed(before: macOS 14.0, iOS 17.0, watchOS 10.0, tvOS 17.0)
static func makeStream(of elementType: Element.Type = Element.self, bufferingPolicy limit: AsyncStream<Element>.Continuation.BufferingPolicy = .unbounded) -> (stream: AsyncStream<Element>, continuation: AsyncStream<Element>.Continuation)
Parameters
- elementType
The element type of the stream.
- limit
The buffering policy that the stream should use.
Returns
A tuple containing the stream and its continuation. The continuation should be passed to the producer while the stream should be passed to the consumer.