Skip to main content

flat_map_chain_factory

tinyflow_framework::runtime::chain_segment

Function flat_map_chain_factory 

Source 
pub fn flat_map_chain_factory<T, O, F>(f: F) -> ChainSegmentFactory
where
    T: Send + 'static,
    O: Clone + Send + 'static,
    F: FlatMapFunction<T, O> + Clone + Send + 'static,