A high-low watermarked back-pressure strategy for a NIOAsyncSequenceProducer.
struct HighLowWatermarks7NIOCore46NIOAsyncSequenceProducerBackPressureStrategiesO16HighLowWatermarkV What are these?49B24This strategy does the following:
On yield it keeps on demanding more elements from the producer as long as the number of buffered elements hasn’t reached the highWatermark.
On consume it starts to demand again from the producer once the number of buffered elements reach the lowWatermark.
import NIOCoreThe core abstractions that make up SwiftNIO.
enum NIOAsyncSequenceProducerBackPressureStrategiesstruct NIOAsyncSequenceProducer<Element, Strategy, Delegate> where Element : Sendable, Strategy : NIOAsyncSequenceProducerBackPressureStrategy, Delegate : NIOAsyncSequenceProducerDelegateThis is an AsyncSequence that supports a unicast AsyncIterator.
protocol NIOAsyncSequenceProducerBackPressureStrategy : SendableA protocol for the back-pressure strategy of the NIOAsyncSequenceProducer.
protocol Sendableinit(lowWatermark: Int, highWatermark: Int) Initializes a new HighLowWatermark.
mutating func didConsume(bufferDepth: Int) -> Bool mutating func didYield(bufferDepth: Int) -> Bool