Struct StreamConfigBuilder 

pub struct StreamConfigBuilder;

Initial builder stage that requires selecting delivery behavior.

Implementations

impl StreamConfigBuilder

pub fn best_effort_delivery( self, ) -> StreamConfigReplayBuilder<BestEffortDelivery>

Delivery that keeps reading while slow consumers lag behind.

Bounded buffers may overflow, so active consumers can observe gaps or dropped output. This policy avoids applying backpressure for slow consumers, but it is not a blanket throughput guarantee; backend implementation and workload shape still matter.

pub fn reliable_for_active_subscribers( self, ) -> StreamConfigReplayBuilder<ReliableDelivery>

Delivery that waits for active subscribers when their buffers are full.

This applies backpressure to process-output reading so active consumers see all chunks delivered inside the library. It does not retain output for consumers that attach later; that is controlled by replay settings.

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