Circulate

Circulate是一个轻量级的发布/订阅框架，支持异步和非异步代码。该项目是为BonsaiDb编写的。虽然BonsaiDb的异步依赖于tokio，但这个crate由于出色的crate flume而与运行时无关。

异步示例

let relay = Relay::default();
let subscriber = relay.create_subscriber();

subscriber.subscribe_to(&"some topic")?;

relay.publish(&"some topic", &AnySerializableType)?;

let message = subscriber.receiver().recv_async().await?;
println!(
    "Received message on topic {}: {:?}",
    message.topic::<String>()?,
    message.payload::<AnySerializableType>()?
);

同步示例

let relay = Relay::default();
let subscriber = relay.create_subscriber();

subscriber.subscribe_to(&"some topic")?;

relay.publish(&"some topic", &AnySerializableType)?;

let message = subscriber.receiver().recv()?;
println!(
    "Received message on topic {}: {:?}",
    message.topic::<String>()?,
    message.payload::<AnySerializableType>()?
);

开源许可

本项目，如同Khonsu Labs的所有项目一样，是开源的。此仓库可在MIT许可证或Apache许可证2.0下获得。

有关贡献的更多信息，请参阅CONTRIBUTING.md。