cortex-ai 0.1.9

An asynchronous flow-based processing framework for building flexible data pipelines with conditional branching and error handling
Documentation 
1
2
3
4
5
6

use super::component::FlowComponent;
use super::types::FlowFuture;

pub trait Processor: FlowComponent {
    fn process(&self, input: Self::Input) -> FlowFuture<'_, Self::Output, Self::Error>;
}