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