pub struct ProcessStreamBuilder;Expand description
Builder for selecting the output stream backend for one process stream.
Backend choice controls stream ownership and fanout. Delivery policy and replay policy are
selected in later builder stages and are independent decisions. The Self::discard entry
short-circuits the chain entirely for stdio that should be routed to /dev/null at the OS
level.
Implementations§
Source§impl ProcessStreamBuilder
impl ProcessStreamBuilder
Sourcepub fn broadcast(
self,
) -> PipedStreamConfig<BroadcastBackend, StreamConfigBuilder>
pub fn broadcast( self, ) -> PipedStreamConfig<BroadcastBackend, StreamConfigBuilder>
Selects the broadcast backend for this stream.
Use this when the same stdout or stderr stream must be consumed concurrently, such as logging plus readiness checks or logging plus collection.
Sourcepub fn single_subscriber(
self,
) -> PipedStreamConfig<SingleSubscriberBackend, StreamConfigBuilder>
pub fn single_subscriber( self, ) -> PipedStreamConfig<SingleSubscriberBackend, StreamConfigBuilder>
Selects the single-subscriber backend for this stream.
Use this when exactly one active consumer should own the stream and accidental concurrent fanout should be rejected early. This backend can reduce coordination overhead in some single-consumer paths, but delivery policy still determines lag behavior.
Sourcepub fn discard(self) -> DiscardedStreamConfig
pub fn discard(self) -> DiscardedStreamConfig
Routes the matching child stdio slot to Stdio::null().
No pipe is allocated, no reader task is spawned, and the resulting stream is a
DiscardedOutputStream that does not expose any consumer methods. Reach for this when only
the exit status matters and the child’s output should be dropped at the OS level.
Trait Implementations§
Source§impl Clone for ProcessStreamBuilder
impl Clone for ProcessStreamBuilder
Source§fn clone(&self) -> ProcessStreamBuilder
fn clone(&self) -> ProcessStreamBuilder
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read more