Struct StreamEmitter 

pub struct StreamEmitter { /* private fields */ }

Event emitter for ProcessRunner events

Provides on(), once(), off(), and emit() methods similar to Node.js EventEmitter.

Implementations

impl StreamEmitter

pub fn new() -> Self

Create a new event emitter

pub async fn on<F>(&self, event: EventType, listener: F)

where F: Fn(EventData) + Send + Sync + 'static,

Register a listener for an event

Arguments

• event - The event type to listen for
• listener - The callback function to invoke

Example

emitter.on(EventType::Stdout, |data| {
    if let EventData::String(s) = data {
        println!("Got stdout: {}", s);
    }
});

pub async fn once<F>(&self, event: EventType, listener: F)

where F: Fn(EventData) + Send + Sync + 'static,

Register a one-time listener for an event

The listener will be removed after it is invoked once.

pub async fn emit(&self, event: EventType, data: EventData)

Emit an event to all registered listeners

Arguments

• event - The event type to emit
• data - The event data to pass to listeners

pub async fn off(&self, event: EventType)

Remove all listeners for an event

Arguments

• event - The event type to clear listeners for

pub async fn listener_count(&self, event: &EventType) -> usize

Get the number of listeners for an event

pub async fn remove_all_listeners(&self)

Remove all listeners for all events

Trait Implementations

impl Debug for StreamEmitter

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

Formats the value using the given formatter.

impl Default for StreamEmitter

fn default() -> Self

Returns the “default value” for a type.