use crate::error::DelayError;
use crate::removable_delay_queue;
use tokio::sync::broadcast;
use tokio_util::sync::CancellationToken;

pub async fn to_broadcast<T>(
    source: removable_delay_queue::Output<(String, usize), T>,
    dest: broadcast::Sender<T>,
    shutdown: CancellationToken,
) -> Result<(), DelayError> {
    loop {
        tokio::select! {
            ev = source.next() => match ev {
                Some(event) => {
                    let _ = dest.send(event); // only errors of there are no listeners, but that's normal
                },
                None => return Err(DelayError::DelayEnded),
            },
            _ = shutdown.cancelled() => return Ok(()),
        }
    }
}