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