#pubsub #framework #async #topic #sync #run-time #bonsai-db

circulate

Lightweight PubSub framework that supports both sync and async

7 releases (4 breaking)

0.5.0 Aug 24, 2023
0.4.0 Feb 28, 2023
0.3.0 Mar 23, 2022
0.2.1 Dec 24, 2021
0.1.0-dev.1 Apr 27, 2021

#692 in Asynchronous

Download history 19/week @ 2024-07-01 40/week @ 2024-07-08 112/week @ 2024-07-15 141/week @ 2024-07-22 169/week @ 2024-07-29 52/week @ 2024-08-05 55/week @ 2024-08-12 37/week @ 2024-08-19 148/week @ 2024-08-26 95/week @ 2024-09-02 90/week @ 2024-09-09 81/week @ 2024-09-16 177/week @ 2024-09-23 88/week @ 2024-09-30 14/week @ 2024-10-07 66/week @ 2024-10-14

351 downloads per month
Used in 10 crates (via bonsaidb-core)

MIT/Apache

21KB
411 lines

Circulate

crate version Live Build Status Documentation for main branch

Circulate is a lightweight PubSub framework that supports both async and non-async code. This project is written for BonsaiDb. While BonsaiDb's async relies upon tokio, this crate is runtime agnostic thanks to the excellent crate flume.

Async Example

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>()?
);

Sync Example

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>()?
);

Open-source Licenses

This project, like all projects from Khonsu Labs, are open-source. This repository is available under the MIT License or the Apache License 2.0.

To learn more about contributing, please see CONTRIBUTING.md.

Dependencies

~2.6–8MB
~74K SLoC