Enumeration

AsyncThrowingStream.Continuation.BufferingPolicy

A strategy that handles exhaustion of a buffer’s capacity. ある戦略、それはあるバッファのもつ容量の枯渇を取り扱います。

Declaration 宣言 

enum AsyncThrowingStream<Element, Failure>.Continuation.BufferingPolicy

Topics 話題

Buffering Policies

case unbounded
Continue to add to the buffer, treating its capacity as infinite.
case bufferingOldest(Int)
When the buffer is full, discard the newly received element. バッファがいっぱいである時、新しく受け取った要素を廃棄します。
case bufferingNewest(Int)
When the buffer is full, discard the oldest element in the buffer. バッファがいっぱいである時、バッファにおいて最古の要素を廃棄します。

See Also 参照

Creating a Continuation-Based Stream

init(Element.Type, bufferingPolicy: AsyncThrowingStream<Element, Failure>.Continuation.BufferingPolicy, (AsyncThrowingStream<Element, Failure>.Continuation) -> Void)
Constructs an asynchronous stream for an element type, using the specified buffering policy and element-producing closure.
struct AsyncThrowingStream.Continuation
A mechanism to interface between synchronous code and an asynchronous stream.