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

use async_pub_sub::{
    DebuggingForwarderLayer, DebuggingPublisherLayer, ForwarderBuilder, ForwarderImpl, Publisher,
    PublisherBuilder, PublisherImpl, Subscriber, SubscriberImpl,
};

#[test_log::test(tokio::test)]
async fn test_logging_forwarder() {
    let mut forwarder = ForwarderBuilder::new()
        .layer(DebuggingForwarderLayer)
        .forwarder(ForwarderImpl::new("forwarder"));

    let mut publisher = PublisherBuilder::new()
        .layer(DebuggingPublisherLayer)
        .publisher(PublisherImpl::new("publisher", 1));
    let mut subscriber = SubscriberImpl::new("subscriber");

    forwarder.subscribe_to(&mut publisher).unwrap();
    subscriber.subscribe_to(&mut forwarder).unwrap();

    publisher.publish("Hello, World!").await.unwrap();

    let message = subscriber.receive().await;
    assert_eq!(message, "Hello, World!");
}