We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
When using the following code:
async fn say_hello(who: &str) -> Vec<String> { let input: Vec<_> = (1..=5).collect(); let results = input .into_co_stream() .map(|i| hello(i, who)) .collect() .await; results } async fn hello(i: i32, who: &str) -> String { println!("Job {i} started"); tokio::time::sleep(std::time::Duration::from_secs(1)).await; let result = format!("Task {i}: Hello {who}"); println!("Job {i} finished with result {result}"); result }
The program outputs:
Starting jobs... Job 1 started Job 2 started Job 3 started Job 4 started Job 5 started Job 5 finished with result Task 5: Hello world
and does not make any progress afterwards
The text was updated successfully, but these errors were encountered:
Thank you for reporting this! This seems like a likely duplicate of #182. I'm going to close this in favor of that.
Sorry, something went wrong.
No branches or pull requests
When using the following code:
The program outputs:
and does not make any progress afterwards
The text was updated successfully, but these errors were encountered: