Crate rmp_ipc[−][src]
Expand description
This project provides an ipc server and client implementation using messagepack. All calls are asynchronous and event based. Client Example:
use rmp_ipc::prelude::*;
/// Callback ping function
async fn handle_ping(ctx: &Context, event: Event) -> IPCResult<()> {
println!("Received ping event.");
ctx.emitter.emit_response(event.id(), "pong", ()).await?;
Ok(())
}
pub struct MyNamespace;
impl MyNamespace {
async fn ping(_ctx: &Context, _event: Event) -> IPCResult<()> {
println!("My namespace received a ping");
Ok(())
}
}
impl NamespaceProvider for MyNamespace {
fn name() -> &'static str {"my_namespace"}
fn register(handler: &mut EventHandler) {
events!(handler,
"ping" => Self::ping,
"ping2" => Self::ping
);
}
}
#[tokio::main]
async fn main() {
// create the client
let ctx = IPCBuilder::new()
.address("127.0.0.1:2020")
// register callback
.on("ping", callback!(handle_ping))
.namespace("mainspace-client")
// register callback inline
.on("something", callback!(ctx, event, async move {
println!("I think the server did something");
ctx.emitter.emit_response_to(event.id(), "mainspace-server", "ok", ()).await?;
Ok(())
}))
.build()
.add_namespace(namespace!(MyNamespace))
.build_client().await.unwrap();
// emit an initial event
let response = ctx.emitter.emit("ping", ()).await.unwrap().await_reply(&ctx).await.unwrap();
assert_eq!(response.name(), "pong");
}Server Example:
use typemap_rev::TypeMapKey;
use rmp_ipc::IPCBuilder;
use rmp_ipc::callback;
struct MyKey;
impl TypeMapKey for MyKey {
type Value = u32;
}
// create the server
IPCBuilder::new()
.address("127.0.0.1:2020")
// register callback
.on("ping", callback!(ctx, event, async move {
println!("Received ping event.");
ctx.emitter.emit_response(event.id(), "pong", ()).await?;
Ok(())
}))
.namespace("mainspace-server")
.on("do-something", callback!(ctx, event, async move {
println!("Doing something");
{
// access data
let mut data = ctx.data.write().await;
let mut my_key = data.get_mut::<MyKey>().unwrap();
*my_key += 1;
}
ctx.emitter.emit_response_to(event.id(), "mainspace-client", "something", ()).await?;
Ok(())
}))
.build()
// store additional data
.insert::<MyKey>(3)
.build_server().await.unwrap();Re-exports
pub use ipc::builder::IPCBuilder;pub use ipc::context;