cortex_ai::flow::source

Trait Source

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

Required Methods§

Source

fn stream( &self, ) -> FlowFuture<'_, SourceOutput<Self::Output, Self::Error>, Self::Error>

Implementors§