rust - 没有为实现 `poll` 的类型找到名为 `Future` 的方法

Question

我正在尝试创建一个允许某人调用 .shutdown() 的结构，这将解决 future (否则未决)。它只能被调用一次。在 Future 特征的实现中，我收到一个错误，指出 poll 没有定义，尽管它存在于 the documentation 中。 (在 impl Future 下)。

尽管我使用 std::future::Future 作为 impl，但我尝试添加 use futures::prelude::* ，这会将预览特征纳入范围。 RLS 和 rustc 都通知我导入未使用，所以这不是问题。

请注意，我没有使用一个简单的 bool 标志，因为我打算让它能够从任何线程调用——这是一个与这里无关的实现细节。

use futures::channel::oneshot; // futures-preview@0.3.0-alpha.17
use std::{
    future::Future,
    pin::Pin,
    task::{Context, Poll},
};

pub struct ShutdownHandle {
    sender: oneshot::Sender<()>,
    receiver: oneshot::Receiver<()>,
}

impl ShutdownHandle {
    pub fn new() -> Self {
        let (sender, receiver) = oneshot::channel();
        Self { sender, receiver }
    }

    pub fn shutdown(self) -> Result<(), ()> {
        self.sender.send(())
    }
}

impl Future for ShutdownHandle {
    type Output = ();

    fn poll(self: Pin<&mut Self>, cx: &mut Context) -> Poll<Self::Output> {
        self.receiver.poll(&mut cx).map(|_| ())
    }
}

fn main() {
    let runner = ShutdownHandle::new();
    assert!(runner.shutdown().is_ok());
}

我收到以下错误:

error[E0599]: no method named `poll` found for type `futures_channel::oneshot::Receiver<()>` in the current scope
  --> src/main.rs:28:23
   |
28 |         self.receiver.poll(&mut cx).map(|_| ())
   |                       ^^^^

我错过了什么？当然有一些方法可以“通过”投票。我每晚都在使用 (2019-07-18)。

Answer 1

这是真的，Receiver不执行 Future ;只有 Pin<&mut Receiver> 确实如此。您需要将类型的固定投影到字段。

当底层类型可能未实现时 Unpin

impl Future for ShutdownHandle {
    type Output = ();

    fn poll(self: Pin<&mut Self>, cx: &mut Context) -> Poll<Self::Output> {
        // I copied this code from Stack Overflow without reading the text that
        // told me how to verify that this code uses `unsafe` correctly.
        unsafe { self.map_unchecked_mut(|s| &mut s.receiver) }.poll(cx).map(|_| ())
    }
}

您必须阅读 pin module彻底了解使用要求 unsafe在这里。

更清洁的解决方案

我喜欢使用辅助库，例如 pin_project ，处理更复杂的投影类型:

#[unsafe_project(Unpin)]
pub struct ShutdownHandle {
    #[pin]
    sender: oneshot::Sender<()>,
    #[pin]
    receiver: oneshot::Receiver<()>,
}

impl Future for ShutdownHandle {
    type Output = ();

    fn poll(self: Pin<&mut Self>, cx: &mut Context) -> Poll<Self::Output> {
        let this = self.project();
        this.receiver.poll(cx).map(|_| ())
    }
}

当基础类型实现Unpin时

Ömer Erden points out future 预览 crate 提供 FutureExt::poll_unpin .此方法采用对实现 Unpin 的类型的可变引用。并创建一个全新的 Pin用它。

自 oneshot::Receiver执行Unpin ，这可以在这里使用:

impl Future for ShutdownHandle {
    type Output = ();

    fn poll(mut self: Pin<&mut Self>, cx: &mut Context) -> Poll<Self::Output> {
        self.receiver.poll_unpin(cx).map(|_| ())
    }
}

另见

• When is it safe to move a member value out of a pinned future?
• Why is a trait not implemented for a type that clearly has it implemented?