simple_pubsub 0.5.3

A simple pubsub use dashmap and mpsc channel.
Documentation
1
2
3
4
5
6
7
8
9
10
11
12
13
# Simple Pubsub

Usage:

```rust
let topic = "lobby";
let broadcaster: Arc<Broadcaster<String>> = Arc::new(Broadcaster::default());
let (id, mut receiver) = broadcaster.clone().subscribe(topic);
broadcaster.publish(topic, Arc::new("hello world".into()));
let data = receiver.recv().await.unwrap();
assert!(id > 0);
assert_eq!(data.as_ref(), "hello world");
```