Circulate is a lightweight async PubSub framework. It currently requires tokio.
This project is written for PliantDb. However, it's a general-purpose PubSub implementation that can be utilized in any tokio-based Rust codebase.
```rust let relay = Relay::default(); let subscriber = relay.create_subscriber().await;
subscriber.subscribe_to("some topic").await;
relay.publish("some topic", &AnySerializableType).await?;
let message = subscriber.receiver().recv_async().await?;
println!(
"Received message on topic {}: {:?}",
message.topic,
message.payload::
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.