Trait Source 

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

Required Methods

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

Implementors