Enum Sink 

pub enum Sink {
    Stdout(StdoutSink),
    File(FileSink),
    FanOut(Vec<Sink>),
}

Enum dispatch for output adapters.

Uses enum dispatch instead of dyn Trait because:

• Async trait methods are not object-safe
• FanOut(Vec<Sink>) requires a sized, concrete type

Variants

Stdout(StdoutSink)

Write NDJSON to stdout.

File(FileSink)

Append NDJSON to a file.

FanOut(Vec<Sink>)

Fan out to multiple sinks.

Implementations

impl Sink

pub fn send<'a>( &'a mut self, result: &'a ProcessResult, ) -> Pin<Box<dyn Future<Output = Result<(), RuntimeError>> + Send + 'a>>

Serialize and deliver a ProcessResult to this sink.

Synchronous sinks (Stdout, File) use block_in_place to avoid blocking the Tokio runtime. Uses Box::pin for the FanOut case to handle recursive async.