Why is my poll_next of tokio_stream::Stream only called once (returning pending)?

[i18nsite]

As shown in the screenshot below, I am accessing my custom stream using while let Some(v) = stream.next().await {}. However, poll_next is only called once, returning pending, and it gets stuck.

code is there https://github.com/i18n-site/rust/blob/main/map_await/src/lib.rs

[notgull]

https://github.com/i18n-site/rust/blob/02eb72ef365077d0a217142b7112f9dd3ecc3619/map_await/src/lib.rs#L36

You need to register the waker() of the Context into something that will wake up the task later. For instance, for a channel, you need to wake the waker when a new item is pushed into the channel.

[i18nsite]

thanks , I use async_stream , it's easy

I have published this package here. I think it is quite convenient and practical. I use it to control the concurrency of S3 uploads.
https://crates.io/crates/map_await

https://crates.io/crates/s3_put
This is using map_unordered with s3_put to control uploads with a concurrency of 3