Crate rmp_ipc[][src]

This project provides an ipc server and client implementation using messagepack. All calls are asynchronous and event based. Client Example:

use rmp_ipc::IPCBuilder;
// create the client
let emitter = IPCBuilder::new()
    .address("127.0.0.1:2020")
    // register callback
    .on("ping", |_ctx, _event| Box::pin(async move {
        println!("Received ping event.");
        Ok(())
    }))
    .build_client().await.unwrap();

// emit an initial event
emitter.emit("ping", ()).await?;

Server Example:

use rmp_ipc::IPCBuilder;
// create the server
IPCBuilder::new()
    .address("127.0.0.1:2020")
    // register callback
    .on("ping", |_ctx, _event| Box::pin(async move {
        println!("Received ping event.");
        Ok(())
    }))
    .build_server().await.unwrap();

Modules

builder
client
context
error
error_event
server
stream_emitter

Structs

Event

A container representing an event and underlying binary data. The data can be decoded into an object representation or read as raw binary data.

IPCBuilder

A builder for the IPC server or client.