如何实现对`async fn（＆mut self）`进行轮询的`Future`？

Posted 2021-05-07

bounty到期在7天内。该问题的答案有资格获得+ 50声望赏金。Rijenkii想要引起更多关注对此问题。

我具有以下结构

struct Test;

impl Test {
    async fn function(&mut self) {}
}

我想在std::future::Future上实现一个futures::Stream（实际上是Test，但基本相同），这会轮询function。我的第一次尝试看起来像这样

impl Future for Test {
    type Output = ();
    fn poll(self: Pin<&mut self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
        match self.function() {
            Poll::Pending => Poll::Pending,
            Poll::Ready(_) => Poll::Ready(()),
        }
    }
}

显然，这没有用。我知道，必须调用一次function，返回的Future必须存储在结构中的某个位置，然后必须对保存的将来进行轮询。因此，我已经尝试过此

struct Test(Option<Box<Pin<dyn Future<Output = ()>>>);
impl Test {
    async fn function(&mut self) {}
    fn new() -> Self {
        let mut s = Self(None);
        s.0 = Some(Box::pin(s.function()));
        s
    }
}

而且，很意外，这也没有用

问题是，在我调用function()之后-我已经获得了&mut的Test引用，因此我无法更改Test变量，因此-无法存储返回的[ Future中的Test。

答案

[我不确定您要实现什么以及为什么实现，但是我怀疑您是基于某些古老的教程或误解并只是使事情变得过于复杂而试图实现Future for Test。

您不必手动实现Future。 async功能

async fn function(...) {...}

实际上只是语法糖在后台翻译成类似的东西
fn function(...) -> Future<()> {...}

您要做的就是以与任何将来相同的方式使用函数的结果，例如在其上使用等待或调用阻塞反应堆，直到完成。例如。根据您的第一个版本，您可以简单地调用：
let mut test = Test{};
test.function().await;