Struct ChannelEvent 

pub struct ChannelEvent { /* private fields */ }

Builder for registering event handlers with filtering.

Use this to subscribe to specific events from the channel:

ChannelEvent::channel(channel, ChannelOptions::with_pid(pid))
    .on_complete(|pid| println!("Process {} completed", pid))
    .on_error(|e| println!("Error: {:?}", e))
    .on_log(|log| println!("Log: {}", log.content));

Implementations

impl ChannelEvent

pub fn channel(channel: Arc<Channel>, options: ChannelOptions) -> Self

Creates a new event subscriber with the given options.

Examples found in repository

examples/simple/main.rs (line 16)

fn main() {
    let engine = EngineBuilder::new().build().unwrap();

    // Launch the engine
    engine.launch();

    let text = include_str!("./workflow.json");

    let workflow_model = WorkflowModel::from_json(text).unwrap();

    let process = engine.build_workflow_process(&workflow_model).unwrap();
    let pid = process.id();

    ChannelEvent::channel(engine.channel(), ChannelOptions::with_pid(pid.to_owned())).on_complete(move |pid| {
        println!("Workflow completed, pid: {}", pid);
    });

    ChannelEvent::channel(engine.channel(), ChannelOptions::with_pid(pid.to_owned())).on_error(move |e| {
        println!("Workflow failed: {:?}", e);
    });

    // Start the workflow process
    process.start();

    loop {
        if process.is_complete() {
            break;
        }
        std::thread::sleep(std::time::Duration::from_millis(100));
    }

    let outputs: serde_json::Value = process.get_outputs().into();
    println!("Outputs: {:#?}", outputs);
}

pub fn on_complete(&self, f: impl Fn(String) + Send + Sync + 'static)

Registers a handler for workflow completion events.

Examples found in repository

examples/simple/main.rs (lines 16-18)

fn main() {
    let engine = EngineBuilder::new().build().unwrap();

    // Launch the engine
    engine.launch();

    let text = include_str!("./workflow.json");

    let workflow_model = WorkflowModel::from_json(text).unwrap();

    let process = engine.build_workflow_process(&workflow_model).unwrap();
    let pid = process.id();

    ChannelEvent::channel(engine.channel(), ChannelOptions::with_pid(pid.to_owned())).on_complete(move |pid| {
        println!("Workflow completed, pid: {}", pid);
    });

    ChannelEvent::channel(engine.channel(), ChannelOptions::with_pid(pid.to_owned())).on_error(move |e| {
        println!("Workflow failed: {:?}", e);
    });

    // Start the workflow process
    process.start();

    loop {
        if process.is_complete() {
            break;
        }
        std::thread::sleep(std::time::Duration::from_millis(100));
    }

    let outputs: serde_json::Value = process.get_outputs().into();
    println!("Outputs: {:#?}", outputs);
}

pub fn on_error(&self, f: impl Fn(&Event<Message>) + Send + Sync + 'static)

Registers a handler for workflow error events.

Examples found in repository

examples/simple/main.rs (lines 20-22)

fn main() {
    let engine = EngineBuilder::new().build().unwrap();

    // Launch the engine
    engine.launch();

    let text = include_str!("./workflow.json");

    let workflow_model = WorkflowModel::from_json(text).unwrap();

    let process = engine.build_workflow_process(&workflow_model).unwrap();
    let pid = process.id();

    ChannelEvent::channel(engine.channel(), ChannelOptions::with_pid(pid.to_owned())).on_complete(move |pid| {
        println!("Workflow completed, pid: {}", pid);
    });

    ChannelEvent::channel(engine.channel(), ChannelOptions::with_pid(pid.to_owned())).on_error(move |e| {
        println!("Workflow failed: {:?}", e);
    });

    // Start the workflow process
    process.start();

    loop {
        if process.is_complete() {
            break;
        }
        std::thread::sleep(std::time::Duration::from_millis(100));
    }

    let outputs: serde_json::Value = process.get_outputs().into();
    println!("Outputs: {:#?}", outputs);
}

pub fn on_event(&self, f: impl Fn(&Event<Message>) + Send + Sync + 'static)

Registers a handler for all matching events.

pub fn on_log(&self, f: impl Fn(&Event<Log>) + Send + Sync + 'static)

Registers a handler for log events.

pub fn on_event_async<F>(&self, f: F)

where F: Fn(&Event<Message>) -> BoxFuture<'static, ()> + Send + Sync + 'static,

Registers an async handler for all matching events.

pub fn on_log_async<F>(&self, f: F)

where F: Fn(&Event<Log>) -> BoxFuture<'static, ()> + Send + Sync + 'static,

Registers an async handler for log events.

Trait Implementations

impl Clone for ChannelEvent

fn clone(&self) -> ChannelEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.