fn reset_streams(
    ex: &Executor,
    streams: &Rc<RwLock<Vec<RwLock<StreamInfo>>>>,
    tx_queue: &Rc<RwLock<Queue>>,
    tx_recv: &mut UnboundedReceiver<PcmResponse>,
    rx_queue: &Rc<RwLock<Queue>>,
    rx_recv: &mut UnboundedReceiver<PcmResponse>
) -> Result<(), AsyncError>