Struct ReliableWithBackpressure 

pub struct ReliableWithBackpressure;

Reliable stream delivery marker that applies backpressure to the child to keep active subscribers gap-free.

Mechanism: When an active subscriber’s buffer is full, the reader task waits before reading more from the child’s pipe. The kernel pipe then fills and the child’s next write blocks. This is the cost paid for reliability.

Scope: The guarantee applies only to subscribers that are currently attached when each chunk is produced. Subscribers that attach later do not retroactively receive earlier chunks from this delivery policy; that is what the replay axis is for.

Trait Implementations

impl Clone for ReliableWithBackpressure

fn clone(&self) -> ReliableWithBackpressure

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ReliableWithBackpressure

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Delivery for ReliableWithBackpressure

fn guarantee(self) -> DeliveryGuarantee

Returns the runtime delivery guarantee represented by this marker.

impl PartialEq for ReliableWithBackpressure

fn eq(&self, other: &ReliableWithBackpressure) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for ReliableWithBackpressure

impl Eq for ReliableWithBackpressure

impl StructuralPartialEq for ReliableWithBackpressure