style(err): format code

taos-error/src/code/mod.rs

@@ -127,17 +127,22 @@ impl PartialEq<i32> for Code {
     }
 }
 
-#[test]
-fn test_code() {
-    let c: i32 = Code::new(0).into();
-    assert_eq!(c, 0);
-    let c = Code::from(0).to_string();
-    assert_eq!(c, "0x0000");
-    dbg!(Code::from(0x200));
-
-    let c: i8 = Code::new(0).into();
-    let mut c: Code = c.into();
-
-    let _: &i32 = &c;
-    let _: &mut i32 = &mut c;
+#[cfg(test)]
+mod tests {
+    use super::Code;
+
+    #[test]
+    fn test_code() {
+        let c: i32 = Code::new(0).into();
+        assert_eq!(c, 0);
+        let c = Code::from(0).to_string();
+        assert_eq!(c, "0x0000");
+        dbg!(Code::from(0x200));
+
+        let c: i8 = Code::new(0).into();
+        let mut c: Code = c.into();
+
+        let _: &i32 = &c;
+        let _: &mut i32 = &mut c;
+    }
 }

taos-error/src/lib.rs

@@ -38,8 +38,8 @@ mod source;
 /// ```
 ///
 /// # Display representations
-#[derive(Error)]
 #[must_use]
+#[derive(Error)]
 pub struct Error {
     /// Error code, will be displayed when code is not 0xFFFF.
     code: Code,

taos-ws/src/consumer/mod.rs

@@ -1074,8 +1074,7 @@ impl TmqBuilder {
             .info
             .build_stream_opt(self.info.to_tmq_url(), false)
             .await?;
-        // let (ws, _) = taos_query::block_in_place_or_global(connect_async(url))?;
-        // let (ws, _) = connect_async(&url).await.map_err(WsTmqError::from)?;
+
         let (mut sender, mut reader) = ws.split();
 
         let version = WsSend::Version;