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, SourceOutput};

pub trait Source: FlowComponent<Input = ()> {
    fn stream(&self) -> FlowFuture<'_, SourceOutput<Self::Output, Self::Error>, Self::Error>;
}