Function http_video_streaming::firehose_task

pub async fn firehose_task(
    connection_callback_rx: Receiver<ConnectionEvent>,
    firehose_rx: Receiver<AnnotatedFrame>,
    firehose_callback_rx: Receiver<FirehoseCallback>
) -> Result<(), Error>