async_pub_sub 0.2.1

A library aiming at making async pub-sub easier in Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

use async_pub_sub::{PublisherImpl, Result, SubscriberImpl};

#[test_log::test(tokio::test)]
async fn test_multiple_publishers() -> Result<()> {
    // -- Setup & Fixtures
    let mut publisher1 = PublisherImpl::new("publisher1", 1);
    let mut publisher2 = PublisherImpl::new("publisher2", 1);
    let mut subscriber = SubscriberImpl::new("subscriber");

    subscriber.subscribe_to(&mut publisher1)?;
    subscriber.subscribe_to(&mut publisher2)?;

    // -- Exec
    publisher1.publish("Hello, publisher1").await?;
    publisher2.publish("Hello, publisher2").await?;

    let message1 = subscriber.receive().await;
    let message2 = subscriber.receive().await;

    // -- Check
    assert_eq!(message1, "Hello, publisher1");
    assert_eq!(message2, "Hello, publisher2");

    Ok(())
}