A strategy for handling exhaustion of a buffer’s capacity.
On This Page
enum BufferingStrategy<Failure> where Failure : Error
When full, discard the newly-received element without buffering it.
When full, remove the least recently-received element from the buffer.
case customError(() -> Failure)
When full, execute the closure to provide a custom error.
A publisher that buffers elements from an upstream publisher.
A strategy for filling a buffer.