pub fn sink_chain_factory<T, F>(f: F) -> ChainSegmentFactorywhere T: Send + 'static, F: SinkFunction<T> + Clone + Send + 'static,