cortex_ai/flow/
source.rs

1use super::component::FlowComponent;
2use super::types::{FlowFuture, SourceOutput};
3
4pub trait Source: FlowComponent<Input = ()> {
5    fn stream(&self) -> FlowFuture<'_, SourceOutput<Self::Output, Self::Error>, Self::Error>;
6}