异步函数参数中性状对象的关联类型声明

Question

我想要一个异步处理可变数量的（Sink，Stream）元组的函数。

use futures::channel::mpsc;
use futures::{Sink, Stream, SinkExt, StreamExt};

async fn foo(v: Vec<(Box<dyn Sink<Error = std::io::Error>>, Box<dyn Stream<Item = u8>>)>) {
    for (mut tx, mut rx) in v {
        let _ = tx.send(0);
        let _ = rx.next().await;
    }
}

#[tokio::main]
pub async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let (tx, mut rx) = mpsc::channel(32);
    foo(vec![(Box::new(tx), Box::new(rx))]).await;
    
    Ok(())
}

但我得到了这个编译错误：

error[E0107]: wrong number of type arguments: expected 1, found 0
 --> src/main.rs:4:30
  |
4 | async fn foo(v: Vec<(Box<dyn Sink<Error = std::io::Error>>, Box<dyn Stream<Item = u8>>)>) {
  |                              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected 1 type argument

编译器本身以这种方式提示我声明trait对象的关联类型。我不确定它为什么不接受它。

Answer 1

编译器希望您指定< code >接收器的“类型参数”。这不是错误类型，而是发送到接收器的项的类型，如在< code >接收器中

这样做后，编译器接下来会抱怨您需要指定Error关联类型（这次是真的）。但是，如果您指定std::io::Error，则从main（）调用foo（）将无法编译，因为mpc::Sender的Sink的实现将其自己的mpc::SendError指定为错误类型。

最后，水槽和溪流都需要固定，以便它们可以跨越等待点。这是通过使用引脚完成的

通过上述更改，编译的版本如下所示：

use futures::channel::mpsc;
use futures::{Sink, SinkExt, Stream, StreamExt};
use std::pin::Pin;

async fn foo(
    v: Vec<(
        Pin<Box<dyn Sink<u8, Error = mpsc::SendError>>>,
        Pin<Box<dyn Stream<Item = u8>>>,
    )>,
) {
    for (mut tx, mut rx) in v {
        let _ = tx.send(0);
        let _ = rx.next().await;
    }
}

#[tokio::main]
pub async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let (tx, rx) = mpsc::channel(32);
    foo(vec![(Box::pin(tx), Box::pin(rx))]).await;

    Ok(())
}