pub enum DeliveryGuarantee {
LossyWithoutBackpressure,
ReliableWithBackpressure,
}Expand description
Runtime delivery behavior used by typed stream modes.
The two variants describe the same trade-off as the typed LossyWithoutBackpressure and
ReliableWithBackpressure markers. Active subscribers either get every chunk at the cost of
pausing the child when their buffer is full, or they tolerate dropped chunks so the child is
never blocked.
Variants§
LossyWithoutBackpressure
Keep reading output and drop chunks for slow subscribers when bounded buffers overflow. The child is never blocked by consumer pace.
ReliableWithBackpressure
Wait for active subscribers before reading more output when bounded buffers are full. The child’s next write blocks once the kernel pipe fills. The reliability scope is limited to subscribers attached at the time each chunk is produced; late attachers depend on the replay axis for earlier output.
Trait Implementations§
Source§impl Clone for DeliveryGuarantee
impl Clone for DeliveryGuarantee
Source§fn clone(&self) -> DeliveryGuarantee
fn clone(&self) -> DeliveryGuarantee
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for DeliveryGuarantee
impl Debug for DeliveryGuarantee
Source§impl PartialEq for DeliveryGuarantee
impl PartialEq for DeliveryGuarantee
Source§fn eq(&self, other: &DeliveryGuarantee) -> bool
fn eq(&self, other: &DeliveryGuarantee) -> bool
self and other values to be equal, and is used by ==.