compio 0.18.0

Completion based async runtime
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use compio::net::ToSocketAddrsAsync;
use futures_util::{StreamExt, stream::FuturesUnordered};

#[compio::main]
async fn main() {
    let mut tasks = std::env::args()
        .skip(1)
        .map(|name| async move {
            (
                (name.as_str(), 0).to_socket_addrs_async().await.unwrap(),
                name,
            )
        })
        .collect::<FuturesUnordered<_>>();
    while let Some((addrs, name)) = tasks.next().await {
        println!("Address of {name}");
        for addr in addrs {
            println!("    {}", addr.ip());
        }
    }
}