Open source project with heavy use of async/await

ivan.b · August 18, 2022, 12:49pm

Hi All!

I want to study Rust's async/await concept more deeply. I've seen some synthetic examples already and now I'm looking for a nice open-source project that could help me see how this approach is used to solve real-world problems.

Can you advice some?

toad47 · August 18, 2022, 2:03pm

You might get some inspiration from a list of crates depending on tokio or async_std.

Heliozoa · August 18, 2022, 2:04pm

The mini-redis project was written to help teach use of tokio, which is the most widely used async runtime, so I imagine it would work well for learning practical async in general as well. Strictly speaking it's not solving a real-world problem since it's incomplete and written purely for teaching purposes, but you may find it useful regardless.

ivan.b · August 19, 2022, 4:36pm

That's a really nice way of looking into it, should be easy to find something in my area of interests. Thank you!

ivan.b · August 19, 2022, 4:37pm

I looked a bit through the code of this project. There are definitely some places which are interesting to me. Thanks!

geebee22 · August 19, 2022, 5:25pm

Here is an async program I have been working on for some time:

github.com

georgebarwood/RustWeb/blob/main/src/main.rs

#![forbid(unsafe_code)]

#[tokio::main]
/// Execution starts here.
async fn main() {
    // console_subscriber::init();

    let args = Args::parse();
    println!(
        "ip={} port={} mem={} rep={} login={}",
        args.ip, args.port, args.mem, args.rep, args.login
    );

    let listen = format!("{}:{}", args.ip, args.port);
    let listen = listen.parse().expect("Error parsing listen address:port");
    let is_master = args.rep == "";
    let replicate_source = args.rep;
    let replicate_credentials = args.login;

    // Construct an AtomicFile. This ensures that updates to the database are "all or nothing".

This file has been truncated. show original

It uses tokio, several kinds of channels, a mixture of sync and async tasks.