rs-broker 1.0.1

rust broker
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

use async_trait::async_trait;
use std::future::Future;

#[async_trait]
pub trait Broker: Send + Sync + 'static {
    // publish message to topic
    async fn publish(&self, topic: &str, msg: &[u8]) -> Result<(), String>;

    // subscribe message from topic consumer group by async handler fn
    async fn subscribe<F, Fut>(&self, topic: &str, group: &str, handler: F) -> Result<(), String>
    where
        F: Fn(Vec<u8>) -> Fut + Send + Sync + 'static,
        Fut: Future<Output = Result<(), String>> + Send + 'static;

    async fn shutdown(&self) -> Result<(), String>;
}