pub async fn handle_ctrl_queue(
    ex: &Executor,
    streams: &Rc<RwLock<Vec<RwLock<StreamInfo>>>>,
    snd_data: &SndData,
    queue: Rc<RwLock<Queue>>,
    queue_event: &mut EventAsync,
    tx_send: UnboundedSender<PcmResponse>,
    rx_send: UnboundedSender<PcmResponse>,
    card_index: usize,
    reset_signal: Option<&(RwLock<bool>, Condvar)>
) -> Result<(), Error>
Expand description

Handle all the control messages from the ctrl queue.