Struct StreamWriter 

pub struct StreamWriter<S: State> { /* private fields */ }

Writer for streaming events from a node

Nodes receive this writer to emit custom streaming events during execution. The writer carries a sender channel, the current node name, stream mode, and namespace stack for subgraph isolation.

Implementations

impl<S: State> StreamWriter<S>

pub const fn new( tx: Sender<StreamEvent<S>>, node: String, mode: StreamMode, ) -> Self

Create a new writer backed by a real channel

pub const fn disconnected(node: String, mode: StreamMode) -> Self

Create a disconnected writer (no-op send)

Used when streaming is not configured for the current execution.

pub fn with_ns(&self, ns_segment: String) -> Self

Create a child writer with an additional namespace segment (for subgraphs)

pub async fn send(&self, data: Value)

Send a custom stream event through the channel.

Silently drops the event if the writer is disconnected or the event does not match the configured StreamMode.

Trait Implementations

impl<S: Clone + State> Clone for StreamWriter<S>

fn clone(&self) -> StreamWriter<S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: State> Debug for StreamWriter<S>

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

Formats the value using the given formatter.