如何在 Rust 中引用 impl 输出的类型？

Question

我正在尝试实现Rust的流以在Tonic GRPC处理程序中使用，并遇到了以下困难：创建流的大多数方法都不容易表达类型，但是我需要实现的GRPC特征需要特定的流类型。这样的东西（简化）：

// trait to implement
trait GrpcHandler {
  type RespStream: futures::Stream<ResponseType> + Send + 'static
  fn get_resp_stream() -> Self::RespStream;
}

// a start at implementing it
impl GrpcHandler for MyHandler {
  type RespStream = ???; // what do I put here?
  fn get_resp_stream() -> Self::RespStream {
    futures::stream::unfold((), |_| async {
      tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
      Some((ResponseType {}, ()))
    })
  }
}

我知道我的流的类型在技术上是类似的东西，例如 from＆lt;（），复杂的fnsignaturewithimpl，complematedfuturesturesignaturewithimpl＆gt; >对它是一种不透明的类型感到高兴。 如何参考此流的类型？

Answer 1

不幸的是，在稳定的 Rust 中没有好的方法可以在没有动态调度的情况下做到这一点。您必须使用dyn Stream，并且futures提供BoxStream ：

impl GrpcHandler for MyHandler {
    type RespStream = futures::stream::BoxStream<'static, ResponseType>;
    fn get_resp_stream() -> Self::RespStream {
        futures::stream::unfold((), |_| async {
            tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
            Some((ResponseType {}, ()))
        })
        .boxed()
    }
}

如果您使用 nightly，则可以使用不稳定的 type_alias_impl_trait 功能可以避免动态调度的开销：

#![feature(type_alias_impl_trait)]

impl GrpcHandler for MyHandler {
    type RespStream = impl futures::Stream<Item = ResponseType> + Send + 'static;
    fn get_resp_stream() -> Self::RespStream {
        futures::stream::unfold((), |_| async {
            tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
            Some((ResponseType {}, ()))
        })
    }
}