突然发现 Rust 没法正常表达这样一个场景.

    pub async fn get_state(&self) -> (usize, bool) {
        let (tx, rx) = tokio::sync::oneshot::channel();
        let ev = Event::GetState(tx);
        loop {
            let ev = match self.ev_q.put(ev).await {
                Ok(_) => break,
                Err(ev) => ev
            };
            tokio::time::sleep(Duration::from_millis(20)).await;
        }
        rx.await.unwrap()
    }

不断调用一个函数 self.ev_q.put, 该函数会获取参数 ev 的所有权. 如果成功则退出循环, 失败则函数会返回参数的所有权; 然后在下一次循环中再次调用. 但是发现 Rust 的 borrow checker 好像无法识别出来这个参数的所有权是始终存在的.

如果要实现的话只能写成这样:

    pub async fn get_state(&self) -> (usize, bool) {
        let (tx, rx) = tokio::sync::oneshot::channel();
        let mut ev = Some(Event::GetState(tx));
        loop {
            let inner = match self.ev_q.put(ev.take().unwrap()).await {
                Ok(_) => break,
                Err(ev) => ev
            };
            ev = Some(inner);
            tokio::time::sleep(Duration::from_millis(20)).await;
        }
        rx.await.unwrap()
    }