Skip to main content

firehose_task

Function firehose_task 

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