Struct StreamConfigBuilder 

pub struct StreamConfigBuilder;

Initial builder stage that requires selecting delivery behavior.

Implementations

impl StreamConfigBuilder

pub fn lossy_without_backpressure( self, ) -> StreamConfigReplayBuilder<LossyWithoutBackpressure>

Lossy delivery that never blocks the child.

Mechanism: the reader task keeps draining the child’s pipe regardless of consumer pace. When a subscriber’s buffer fills, that subscriber’s chunk is dropped instead of pausing the child.

Cost: slow active consumers may observe gaps or dropped output. Line-aware consumers discard the in-progress partial line and resync at the next newline rather than splicing across the gap.

pub fn reliable_with_backpressure( self, ) -> StreamConfigReplayBuilder<ReliableWithBackpressure>

Reliable delivery to active subscribers, paid for with backpressure on the child.

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. That blocking is the cost of reliability.

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

Trait Implementations

impl Clone for StreamConfigBuilder

fn clone(&self) -> StreamConfigBuilder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamConfigBuilder

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

Formats the value using the given formatter.

impl PartialEq for StreamConfigBuilder

fn eq(&self, other: &StreamConfigBuilder) -> 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 StreamConfigBuilder

impl Eq for StreamConfigBuilder

impl StructuralPartialEq for StreamConfigBuilder