Struct EventEmitter 

pub struct EventEmitter<S: State> {
    pub tx: Sender<StreamEvent<S>>,
    pub mode: StreamMode,
    /* private fields */
}

Event emitter for streaming

Fields

tx: Sender<StreamEvent<S>>

mode: StreamMode

Implementations

impl<S: State> EventEmitter<S>

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

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

Create a child emitter with an additional subgraph namespace segment.

Used by subgraph execution to namespace streaming events, allowing consumers to distinguish events from nested subgraphs.

pub fn ns(&self) -> &[String]

Return the current namespace stack.

pub const fn mode(&self) -> &StreamMode

Return the stream mode for this emitter.

pub async fn emit(&self, event: StreamEvent<S>)

Emit an event to the stream.

Silently drops the event if the receiver has been closed, matching the design intent that stream consumers may disconnect at any time without disrupting execution.

pub fn stream_writer(&self, node: String) -> StreamWriter<S>

pub fn should_emit(&self, event: &StreamEvent<S>) -> bool

pub fn has_nostream_tag(&self, options: Option<&CallOptions>) -> bool

Check if CallOptions contains “nostream” tag.

This method provides the public API for checking whether LLM call options include the “nostream” tag, which suppresses streaming for that specific call.

Examples

use juncture_core::stream::EventEmitter;
use juncture_core::llm::CallOptions;

let emitter = EventEmitter::new(tx, StreamMode::Messages);

// No options - no nostream tag
assert!(!emitter.has_nostream_tag(None));

// Options with nostream tag
let options = CallOptions {
    tags: vec!["nostream".to_string()],
    ..Default::default()
};
assert!(emitter.has_nostream_tag(Some(&options)));

// Options without nostream tag
let options = CallOptions {
    tags: vec!["fast".to_string()],
    ..Default::default()
};
assert!(!emitter.has_nostream_tag(Some(&options)));

Trait Implementations

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

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

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

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

Formats the value using the given formatter.