halo-agent 0.1.1

Halo Agent and Workflow execution kernel
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

//! Small concrete Nodes that exercise the shared Node contract.

use crate::{
    Cancellation, Error, Messages,
    components::node::{Node, Signal},
};

/// Pass input through unchanged. Useful as a lightweight Workflow node.
pub struct Echo;

impl Node<Messages, Messages, Error> for Echo {
    async fn call(
        &self,
        input: Messages,
        _cancellation: &Cancellation,
    ) -> Result<Signal<Messages>, Error> {
        Ok(Signal::Complete(input))
    }
}