+
+
+ 
+
+Asynchronous event driven interprocess communication supporting tcp and unix domain sockets.
@@ -138,10 +146,6 @@ async fn main() { } ``` -## Benchmarks - -Benchmarks are generated on each commit. They can be reviewed [here](https://trivernis.github.io/rmp-ipc/report/). - ## License Apache-2.0 \ No newline at end of file diff --git a/src/events/event.rs b/src/events/event.rs index 59475f31..2ad6a441 100644 --- a/src/events/event.rs +++ b/src/events/event.rs @@ -103,7 +103,7 @@ impl Event { /// It represents the message that is replied to and can be None. #[inline] pub fn reference_id(&self) -> Option {
self.emitter.emit_raw(
self.clone(),
- self.ref_id.clone(),
+ self.ref_id,
name,
namespace,
event_type,
diff --git a/src/ipc/server.rs b/src/ipc/server.rs
index c88d238a..ec88fa93 100644
--- a/src/ipc/server.rs
+++ b/src/ipc/server.rs
@@ -48,7 +48,7 @@ impl IPCServer {
let handler = Arc::clone(&handler);
let namespaces = Arc::clone(&namespaces);
let data = Arc::clone(&data);
- let timeout = self.timeout.clone();
+ let timeout = self.timeout;
#[cfg(feature = "serialize")]
let default_serializer = self.default_serializer.clone();
@@ -69,7 +69,7 @@ impl IPCServer {
default_serializer.clone(),
);
#[cfg(not(feature = "serialize"))]
- let ctx = Context::new(emitter, data, None, reply_listeners, timeout.into());
+ let ctx = Context::new(emitter, data, None, reply_listeners, timeout);
handle_connection:: {
let payload = self.payload.take().ok_or(Error::InvalidState)?;
let res_id = self.res_id.take().ok_or(Error::InvalidState)?;
let event_type = self.event_type.take().ok_or(Error::InvalidState)?;
- let payload_bytes = payload.into_payload(&ctx)?.into();
+ let payload_bytes = payload.into_payload(&ctx)?;
let event = Event::new(
namespace,
- event.to_string(),
+ event,
payload_bytes,
res_id,
event_type,