#request-response #tokio #ids #synchronize #receive #message

aligne

A small crate using tokio to synchronize asynchronous request/response with Ids

1 unstable release

0.1.0 May 13, 2022

#1927 in Asynchronous

MIT license

8KB
164 lines

aligne

A small crate using tokio to synchronize asynchronous request/response with Ids.


lib.rs:

aligne

A crate to help synchronizing asynchronous request / responses.

Example:

#[tokio::main]
pub async fn main() {
    let handle = aligne::ResponseManager::spawn();
    let remote_a = handle.remote();
    let remote_b = remote_a.clone();

    let _h1 = tokio::spawn(async move {
        let msg = remote_b.request(2).await;
        assert_eq!(msg, "message 2");
        let msg = remote_b.request(1).await;
        assert_eq!(msg, "message 1");
    });

    let _h2 = tokio::spawn(async move {
        remote_a.receive(1, "message 1").await;
        remote_a.receive(2, "message 2").await;
    });

    _h1.await.unwrap();
    _h2.await.unwrap();
}

Dependencies

~2.4–8.5MB
~57K SLoC