feat: add some macros

Author: Jeff Tsai

rsocket/src/lib.rs

@@ -95,7 +95,6 @@
 pub use async_stream::stream;
 /// A re-export of [`async-trait`](https://docs.rs/async-trait) for use with RSocket trait implementation.
 pub use async_trait::async_trait;
-use cfg_if::cfg_if;
 
 #[macro_use]
 extern crate anyhow;
@@ -104,8 +103,16 @@ extern crate log;
 #[macro_use]
 extern crate cfg_if;
 
+#[macro_use]
+#[doc(hidden)]
+pub mod macros;
+
 pub mod error;
 pub mod extension;
+pub mod prelude;
+pub mod runtime;
+pub mod transport;
+pub mod utils;
 
 cfg_if! {
     if #[cfg(feature = "frame")]{
@@ -117,11 +124,7 @@ cfg_if! {
 
 mod core;
 mod payload;
-pub mod prelude;
-pub mod runtime;
 mod spi;
-pub mod transport;
-pub mod utils;
 
 pub type Error = Box<dyn std::error::Error + Sync + Send>;
 pub type Result<T> = anyhow::Result<T>;

rsocket/src/macros/composite.rs

@@ -0,0 +1,33 @@
+#[macro_export]
+macro_rules! composite {
+    ($($x:expr,$y:expr),+) => {
+        {
+            let mut b = $crate::extension::CompositeMetadata::builder();
+            $(
+                b = b.push($x.into(),$y);
+            )*
+            b.build()
+        }
+    }
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn test_composite() {
+        let c = composite!("application/json", "123", "text/plain", "ccc");
+        let vv: Vec<_> = c
+            .iter()
+            .map(|it| {
+                format!(
+                    "{}={}",
+                    it.get_mime_type(),
+                    it.get_metadata_utf8().unwrap_or_default()
+                )
+            })
+            .collect();
+        assert_eq!(vv.join(","), "application/json=123,text/plain=ccc");
+    }
+}

rsocket/src/macros/mod.rs

@@ -0,0 +1,4 @@
+#[macro_use]
+mod composite;
+#[macro_use]
+mod routing;

rsocket/src/macros/routing.rs

@@ -0,0 +1,25 @@
+#[macro_export]
+macro_rules! tags {
+    ($($v:expr),+) => {
+        {
+            let mut b = $crate::extension::RoutingMetadata::builder();
+            $(
+                b = b.push_str($v);
+            )*
+            b.build()
+        }
+    }
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn test_routing() {
+        let t = tags!("a", "b", "c");
+        let tags = t.get_tags();
+        println!("{:?}", tags);
+        assert_eq!("a,b,c", t.get_tags().join(","))
+    }
+}

rustfmt.toml

@@ -1,3 +1,2 @@
 edition = "2018"
 group_imports="StdExternalCrate"
-