Macrofy end of data PDU tests

Author: DRiKE

src/rtr/pdu.rs

@@ -1879,33 +1879,40 @@ mod test {
         );
     }
 
-    #[tokio::test]
-    async fn end_of_data_versions() {
-        for (version, raw) in [
-            (0,
-             vec![0, 7, 0x12, 0x34,   0, 0, 0, 12,  0xde, 0xad, 0xbe, 0xef]
-            ),
-            (1,
-             vec![0x01, 0x07, 0x8e, 0xef, 0x00, 0x00, 0x00, 0x18,
-             0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, 0x8f,
-             0x00, 0x00, 0x02, 0x58, 0x00, 0x00, 0x1c, 0x20
-             ]
-            ),
-            (2,
-             vec![0x02, 0x07, 0x8e, 0xef, 0x00, 0x00, 0x00, 0x18,
-             0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, 0x8f,
-             0x00, 0x00, 0x02, 0x58, 0x00, 0x00, 0x1c, 0x20
-             ]
-            )
-        ] {
-            if let Err(eod) = Payload::read(&mut raw.as_slice()).await.unwrap() {
-                assert_eq!(version, eod.version());
+    macro_rules! test_eod_pdu_version {
+        ($version:expr, $raw:expr) => {
+            if let Err(eod) = Payload::read(&mut $raw.as_slice()).await.unwrap() {
+                assert_eq!($version, eod.version());
             } else {
                 panic!("expected End of Data PDU");
             }
         }
     }
 
+    #[tokio::test]
+    async fn end_of_data_versions() {
+        test_eod_pdu_version!(
+            0,
+            vec![0, 7, 0x12, 0x34, 0, 0, 0, 12,  0xde, 0xad, 0xbe, 0xef]
+        );
+        test_eod_pdu_version!(
+            1,
+            vec![
+                0x01, 0x07, 0x8e, 0xef, 0x00, 0x00, 0x00, 0x18,
+                0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, 0x8f,
+                0x00, 0x00, 0x02, 0x58, 0x00, 0x00, 0x1c, 0x20
+            ]
+        );
+        test_eod_pdu_version!(
+            2,
+            vec![
+                0x02, 0x07, 0x8e, 0xef, 0x00, 0x00, 0x00, 0x18,
+                0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, 0x8f,
+                0x00, 0x00, 0x02, 0x58, 0x00, 0x00, 0x1c, 0x20
+            ]
+        );
+    }
+
     #[tokio::test]
     async fn read_write_cache_reset() {
         read_write!(