Function prioritized_broadcast 

pub fn prioritized_broadcast<T: Stream<Item = Result<String>> + Send + Unpin + 'static>(
    lines: T,
    fallback_receiver: impl Fn(String) + Send + 'static,
) -> PriorityBroadcast