StreamExt::forward 出现错误 `expected integer, found enum `std::result::Result``。

Question

StreamExt::forward 出现错误 `expected integer, found enum `std::result::Result``。

3

我正在尝试将rust futures流（repeat）连接到一个接收器（drain）。第一种方法很好地工作（请参见以下内容），但第二种使用.forward的方法无法编译（错误显示在行内）。有什么指针可以告诉我我做错了什么吗？

use futures::stream::StreamExt;
use futures::sink::SinkExt;
use futures::executor;

fn main() {
    executor::block_on( async {
        // works
        let mut work = futures::stream::repeat(5);
        let mut drain = futures::sink::drain();
        match drain.send(work.next()).await {
            Ok(_r) => println!("Done"),
            Err(_e) => println!("Error"),
        };

        // works
        let res: Vec<i32> = futures::stream::repeat(5).take(3).collect::<Vec<i32>>().await;
        println!("{:?}", res);

        // doesn't work
        // futures::stream::repeat(5).forward(futures::sink::drain());
        //                            ^^^^^^^ expected integer, found enum `std::result::Result`
        //  error[E0271]: type mismatch resolving `<futures_util::stream::repeat::Repeat<{integer}> as futures_core::stream::Stream>::Item == std::result::Result<_, _>`

        // Fixed above with repeat(Ok(5)) but not repeat(5)
        match futures::stream::repeat(Ok(5)).take(3).forward(futures::sink::drain()).await {
            Ok(_r) => println!("Done"),
            Err(_e) => println!("Error"),
        };
    });
}

相关文档

https://docs.rs/futures/0.3.1/futures/stream/fn.repeat.html - 重复地产生给定的元素。
https://docs.rs/futures/0.3.1/futures/sink/fn.drain.html - 将所有输入项都丢弃掉，直到接收者准备就绪。
https://docs.rs/futures/0.3.1/futures/stream/trait.StreamExt.html#method.forward - 将此流的所有项发送到提供的sink中。

- Shadi

你说得对。已经修复了。 - Shadi

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- w08r · Answer 1

我猜你想要的更像是这样的吧？

use futures::stream::StreamExt;
use futures::sink::SinkExt;

#[tokio::main]
async fn main() {
    // works
    let mut work = futures::stream::repeat(5);
    let mut drain = futures::sink::drain();
    match drain.send(work.next()).await {
        Ok(_r) => println!("Done"),
        Err(_e) => println!("Error"),
    };
    // doesn't work

    futures::stream::repeat(Ok(5)).forward(futures::sink::drain());
}

正如错误信息（有点令人困惑）所示，在这种情况下，重复调用必须带有一个Result参数。