Struct FanOutSink 

pub struct FanOutSink { /* private fields */ }

Multiplex a single tier’s output across N sinks.

Construction enforces !sinks.is_empty() — a zero-child fan-out is almost certainly a config mistake (silent drop of every envelope); the empty case is better served by an explicit NoopSink.

Implementations

impl FanOutSink

pub fn new(sinks: Vec<Arc<dyn Sink>>) -> Arc<FanOutSink>

Wrap sinks as a shared Arc<dyn Sink>.

Panics

Panics when sinks is empty — caller bug.

pub fn children(&self) -> usize

Number of child sinks.

Trait Implementations

impl Debug for FanOutSink

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

Formats the value using the given formatter.

impl Sink for FanOutSink

fn deliver(&self, env: ScrubbedEnvelope<'_>)

Hand the envelope to the sink. Must not block; long IO is queued internally. Spec 11 § 4 / spec 14 § 5.

fn flush(&self) -> Pin<Box<dyn Future<Output = ()> + Send + '_>>

Flush in-flight batches; awaits IO if needed.

fn shutdown(&self) -> Pin<Box<dyn Future<Output = ()> + Send + '_>>

Shut down (drain + close). Idempotent.