Function hydro_deploy::util::prioritized_broadcast

source ยท 
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<UnboundedSender<String>>>>)