store

src/socket/event.rs

@@ -13,7 +13,7 @@ pub trait BusinessEvent {
         key: Option<impl AsRef<str>>,
         header: Header,
         status: Status,
-        extra: Option<impl AsRef<str>>,
+        extra: impl AsRef<str>,
     ) -> SocketEvent;
 }
 
@@ -22,7 +22,7 @@ impl BusinessEvent for SocketEvent {
         key: Option<impl AsRef<str>>,
         header: Header,
         status: Status,
-        extra: Option<impl AsRef<str>>,
+        extra: impl AsRef<str>,
     ) -> SocketEvent {
         let Header(msg_id, msg_ty, qos) = header;
         SocketEvent {
@@ -40,7 +40,7 @@ impl BusinessEvent for SocketEvent {
             msg_ty: Some(msg_ty),
             status: status as i32,
             desc: qos.desc(),
-            extra: extra.map(|s| s.as_ref().to_string()),
+            extra: Some(extra.as_ref().to_string()),
         }
     }
 }