# Taps - (Tokio Async Pub/Sub)

[<img alt="github" src="https://img.shields.io/badge/github-matthewjberger/taps-8da0cb?style=for-the-badge&labelColor=555555&logo=github" height="20">](https://github.com/matthewjberger/taps)
[<img alt="crates.io" src="https://img.shields.io/crates/v/taps.svg?style=for-the-badge&color=fc8d62&logo=rust" height="20">](https://crates.io/crates/taps)
[<img alt="docs.rs" src="https://img.shields.io/badge/docs.rs-taps-66c2a5?style=for-the-badge&labelColor=555555&logo=docs.rs" height="20">](https://docs.rs/taps)

`taps` is an in-process async message broker built on the tokio runtime that allows multiple clients to communicate with each other through a central broker, routing messages based on topics.

## Features

- **Topic-based Routing**: Easily send and receive messages based on topics.
- **Asynchronous**: Built for asynchronous environments, utilizing the power of Tokio.
- **Scalable**: Designed to handle multiple clients communicating simultaneously.

## Quick Start

### Installation

Add the following to your `Cargo.toml`:

```toml
[dependencies]
taps = "0.2.2"
tokio = { version = "1.33.0", features = ["full"] }
```

### Usage

```rust
use taps::{Broker, Client};

#[tokio::main]
async fn main() {
    let mut broker = Broker::new();
    let (worker_tx, worker_rx) = tokio::sync::mpsc::channel(32);
    tokio::spawn(async move {
        broker.run(worker_rx).await;
    });

    let mut client1 = Client::new(worker_tx.clone());
    client1.subscribe("topic1".to_string()).await;

    let mut client2 = Client::new(worker_tx.clone());
    client2.subscribe("topic1".to_string()).await;

    client1
        .publish("topic1".to_string(), "Hello from client1!".to_string())
        .await;
    if let Some(msg_from_client2) = client2.receive("topic1").await {
        println!("{msg_from_client2}"); // Outputs: "Hello from client1!"
    }
}
```