mqb

This library provides lock free in memory message queue broker.

[dependencies]
mqb = "0.2"

Usage example

use mqb::MessageQueueBroker;

#[tokio::main]
async fn main() {
    let mqb = MessageQueueBroker::unbounded();
    let sub = mqb.subscribe(1);

    assert!(mqb.send(&1, 1).await.is_ok());
    assert_eq!(sub.recv().await.unwrap(), 1);
}