async_stream流类型

Question

考虑以下最小流示例：

use futures::StreamExt;
use async_stream::stream;

#[tokio::main]
async fn main() {
    let ticks = stream! {
        yield Ok(0);
        yield Err("");
    };
    futures::pin_mut!(ticks);
    while let Some(x) = ticks.next().await {
        println!("{:?}", x);
    }
}

ticks 的适当类型是什么？

这个简单的问题使我无法创建一个函数。正确的类型应与功能签名一起使用。

use futures::StreamExt;
use async_stream::stream;

fn query() -> ???? {
    return stream! {
        yield Ok(0);
        yield Err("");
    };
}

#[tokio::main]
async fn main() {
    let ticks = query();
    futures::pin_mut!(ticks);
    while let Some(x) = ticks.next().await {
        println!("{:?}", x);
    }
}

您如何找到类型？

Answer 1

实际类型是 ，但是您不应该指定两个原因：出于两个原因：

1. 您 you y you> you> em> em> em> em> em> em> em> em>它，因为您无法命名 [some_compiler_generated_future_type] 。
2. 即使您避开了此问题（例如，使用 Impl特征）， asyncstream 在 async_stream 的s文档中都没有提及，因为它已被标记＃[doc（hidden）] - 这是图书馆的作者认为它可能会改变的实现细节，并期望您不依赖它。

图书馆文档没有提及如何做到这一点，这是非常不幸的，但是鉴于我们想返回“某些流”，我们可以使用 Impl＆lt; item = farvedtype＆gt; 来表达它。您不能在本地变量声明中执行此操作（却是），但是您可以在功能返回类型位置：

fn query() -> impl futures::Stream<Item = Result<i32, &'static str>>