最近在封装一点lib，本来想在trait里面定义async fn的，但是目前来说是不允许的.Async Methods I: generic associated types，只能想其他办法咯，那我们就再调用async fn返回个future吧，也一样的。
然后问题又来了，本来想是return 一个 impl Future，但是。。。trait里面又不允许，sad！
Async Methods I: generic associated types这里也解释了为什么直接associated types不行。
原因就是async返回的Future是个闭包，把所有东西的lifetime都丢进去了，如果我们要写associated types需要这样:
trait Foo { type _Future<'a>: Future<Output = i32> + 'a; fn foo_method<'a>(&'a self) -> Self::_Future<'a>; } 但是呢。。。问题又来了，目前associated types不支持lifetime参数，这个东西叫generic associated types
不过还好，我们还有existential type，参考RFC
#![feature(async_await, existential_type)] use futures::compat::Future01CompatExt; use futures::compat::Stream01CompatExt; use futures::future::{FutureExt, TryFutureExt}; use futures::stream::{StreamExt, TryStreamExt}; use futures::Future; use reqwest::r#async::{Client, ClientBuilder, Decoder}; use std::io::{self, Write}; trait Fuck { type AsyncResult: Future<Output=()>; fn download(&self) -> Self::AsyncResult; } struct Down; impl Down { pub fn new() -> Self{ Down{} } } impl Fuck for Down { existential type AsyncResult: Future<Output=()>; fn download(&self) -> Self::AsyncResult { download() } } async fn download() { let client = ClientBuilder::new().build().unwrap(); let res = client .get("https://dev.to/x1957/rust-async-await-2l4c") .send() .compat() .await; let mut body = res.unwrap().into_body().compat(); while let Some(next) = body.next().await { let chunk = next.unwrap(); io::stdout().write_all(&chunk).unwrap(); } println!("\nDone"); } fn call<T: Fuck>(x: T)->T::AsyncResult { x.download() } fn main() { // let fut = download().unit_error().boxed().compat(); let fut = call(Down::new()).unit_error().boxed().compat(); tokio::run(fut); } 我们定义了Fuck这个trait里面有个associated type AsyncResult，在我们impl这个trait的使用通过existential type来指出AsyncResult是impl Future的即可。
现在使用的时候需要打开feature existential_type
Top comments (0)