cortex_ai/flow/
source.rs

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