async-task-group

Credit

This codebase is based on the task-group project by Pat Hickey.

Examples

Create an echo tcp server which processes incoming connections in a loop without ever creating any dangling tasks:

```rust use asyncstd::io; use asyncstd::net::{TcpListener, TcpStream}; use asyncstd::prelude::*; use asyncstd::task;

async fn process(stream: TcpStream) -> io::Result<()> { println!("Accepted from: {}", stream.peer_addr()?);

let mut reader = stream.clone();
let mut writer = stream;
io::copy(&mut reader, &mut writer).await?;

Ok(())

}

[async_std::main]

async fn main() -> io::Result<()> { let listener = TcpListener::bind("127.0.0.1:8080").await?; println!("Listening on {}", listener.local_addr()?);

let handle = async_task_group::group(|group| async move {
    let mut incoming = listener.incoming();
    while let Some(stream) = incoming.next().await {
        let stream = stream?;
        group.spawn(async move { process(stream).await });
    }
    Ok(group)
});
handle.await?;
Ok(())

} ```

Installation

sh $ cargo add async-task-group

Safety

This crate uses #![deny(unsafe_code)] to ensure everything is implemented in 100% Safe Rust.

Contributing

Want to join us? Check out our "Contributing" guide and take a look at some of these issues:

• Issues labeled "good first issue"
• Issues labeled "help wanted"

License

<sup>Licensed under either of Apache License, Version 2.0 or MIT license at your option.</sup>

<sub>Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in this crate by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.</sub>