1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52
//! This project provides an ipc server and client implementation using //! messagepack. All calls are asynchronous and event based. //! Client Example: //! ```no_run //! use rmp_ipc::IPCBuilder; //! // create the client //! # async fn a() { //! //! let ctx = IPCBuilder::new() //! .address("127.0.0.1:2020") //! // register callback //! .on("ping", |ctx, event| Box::pin(async move { //! println!("Received ping event."); //! ctx.emitter.emit_response(event.id(), "pong", ()).await?; //! Ok(()) //! })) //! .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: //! ```no_run //! use rmp_ipc::IPCBuilder; //! // create the server //!# async fn a() { //! IPCBuilder::new() //! .address("127.0.0.1:2020") //! // register callback //! .on("ping", |ctx, event| Box::pin(async move { //! println!("Received ping event."); //! ctx.emitter.emit_response(event.id(), "pong", ()).await?; //! Ok(()) //! })) //! .build_server().await.unwrap(); //! # } //! ``` #[cfg(test)] mod tests; pub mod error; mod events; mod ipc; pub use events::error_event; pub use events::event::Event; pub use ipc::builder::IPCBuilder; pub use ipc::*;