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