pub async fn send_pcm_response_worker( queue: Rc<RwLock<Queue>>, recv: &mut UnboundedReceiver<PcmResponse>, reset_signal: Option<&(RwLock<bool>, Condvar)>, ) -> Result<(), Error>