[tokio::main]

async fn main() { // create the client let ctx = IPCBuilder::::new() .address("127.0.0.1:2020") // register callback .on("ping", callback!(handleping)) .buildclient().await.unwrap();

// emit an initial event let response = ctx.emitter.emit("ping", ()).await?.await_response(&ctx).await?; } ```

Server:

```rust use bromine::prelude::*; use tokio::net::TcpListener; // create the server

[tokio::main]

async fn main() { IPCBuilder::::new() .address("127.0.0.1:2020") // register callback .on("ping", callback!(ctx, event, async move { println!("Received ping event."); Ok(()) })) .build_server().await.unwrap(); } ```

Namespaces

Client:

```rust use bromine::prelude::*; use tokio::net::TcpListener; // create the client

[tokio::main]

async fn main() { let ctx = IPCBuilder::::new() .address("127.0.0.1:2020") // register namespace .namespace("mainspace-client") // register callback (without macro) .on("ping", |ctx, _event| Box::pin(async move { println!("Received ping event."); Ok(()) })) .build() .buildclient().await.unwrap();

// emit an initial event let response = ctx.emitter.emitto("mainspace-server", "ping", ()).await? .awaitresponse(&ctx).await?; } ```

Server:

```rust use bromine::prelude::*; use tokio::net::TcpListener; // create the server

pub struct MyNamespace;

impl MyNamespace { async fn ping(_ctx: &Context, _event: Event) -> Result<()> { println!("My namespace received a ping"); Ok(()) } }

 fn register<S: AsyncProtocolStream>(handler: &mut EventHandler<S>) {
     events!(handler, 
        "ping" => Self::ping
     );
 }