1 unstable release
new 0.1.0 | Nov 16, 2024 |
---|
#969 in Asynchronous
43 downloads per month
20KB
513 lines
async-stream-lite
It's async-stream
, but without proc macros.
use async_stream_lite::async_stream;
use futures_util::{pin_mut, stream::StreamExt};
#[tokio::main]
async fn main() {
let stream = async_stream(|r#yield| async move {
for i in 0..3 {
r#yield(i).await;
}
});
pin_mut!(stream);
while let Some(value) = stream.next().await {
println!("got {}", value);
}
}
#![no_std]
support
async-stream-lite
supports #![no_std]
on nightly Rust (due to the usage of the unstable #[thread_local]
attribute). To enable #![no_std]
support, enable the unstable-thread-local
feature.
Dependencies
~72KB