pub fn prioritized_broadcast<T: Stream<Item = Result<String>> + Send + Unpin + 'static>( lines: T, default: impl Fn(String) + Send + 'static, ) -> (Arc<Mutex<Option<Sender<String>>>>, Arc<Mutex<Vec<PrefixFilteredChannel>>>)