hanabi-core 0.1.0-alpha.2

Core library for Hanabi
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

use crate::engines::pubsub::message::Message;
use tokio::sync::mpsc;

pub enum PubSubCommand {
    Publish {
        topic: String,
        message: Message,
    },
    Subscribe {
        topic: String,
        subscriber: mpsc::Sender<Message>,
    },
    Unsubscribe {
        topic: String,
        subscriber: mpsc::Sender<Message>,
    },
}