Skip to main content

source_chain_factory

tinyflow_framework::runtime::chain_segment

Function source_chain_factory 

Source 
pub fn source_chain_factory<T, S, F>(
    factory: Arc<Mutex<F>>,
) -> ChainSegmentFactory
where
    T: Send + 'static,
    S: SourceFunction<T> + Send + 'static,
    F: Fn() -> S + Send + 'static,