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
#[macro_use]
extern crate serde_derive;
#[macro_use]
extern crate thiserror;
#[doc(hidden)]
pub mod bus_message;
mod error;
mod events;
mod id;
mod request;
pub use error::*;
pub use events::*;
pub use id::*;
pub use request::*;
use serde::de::DeserializeOwned;
use serde::Serialize;
pub type Result<T> = anyhow::Result<T>;
#[async_trait::async_trait]
pub trait Context {
async fn call<T, R>(&self, service_name: &str, request: Request<T>) -> Result<Response<R>>
where
T: Serialize + Send + Sync,
R: DeserializeOwned + Send + Sync;
async fn notify<T: Serialize + Send + Sync>(&self, service_name: &str, request: Request<T>);
}