Warning

This post was published 37 days ago. The information described in this article may have changed.

Info

This post is auto-generated from RSS feed The Rust Programming Language Forum - Latest topics. Source: Trait for Stream needs buffer_unordered to make it work

Hello,

Could you please tell me why I need to add .buffer_unordered(n) to make this work? My understanding is that map is also returning Stream...

Also, is there a best practice for Stream in a trait? If I worked with Iterator, I would implement it for IntoIter instead of Iterator, but IntoStream does not exist...

Thank you.

use futures::stream;
use futures::stream::StreamExt;
trait FooBar {
    async fn do_something(self) -> Result<Vec<String>, String>;
}
impl<T> FooBar for T
where
    T: Stream<Item = Result<String, String>> + std::marker::Unpin,
{
    async fn do_something(mut self) -> Result<Vec<String>, String> {
        let mut out = Vec::new();
        // just a simple example
        while let Some(i) = self.next().await {
            out.push(i?);
        }
        Ok(out)
    }
}
async fn abcdef() -> Result<Vec<String>, String> {
    let out: Vec<Result<String, String>> = vec![Ok("a".to_owned()), Ok("b".to_owned())];

    // works
    // stream::iter(out.map(|inp| async { inp }).buffer_unordered(8).do_something().await

    // does not work
    stream::iter(out)
        .map(|inp|
        // just a simple example
        async { inp })
        .do_something()
        .await
}

2 posts - 2 participants

Read full topic

🏷️ Rust_feed