Implment test for multpayload

1c3t3a · Apr 10, 2024 · f4f4094 · f4f4094
1 parent 1ba8111
commit f4f4094
Show file tree

Hide file tree

Showing 2 changed files with 46 additions and 0 deletions.
diff --git a/socketio/src/asynchronous/client/client.rs b/socketio/src/asynchronous/client/client.rs
@@ -1064,6 +1064,29 @@ mod test {
             )
         );
 
+        let packet: Option<Packet> = Some(socket_stream.next().await.unwrap()?);
+
+        assert!(packet.is_some());
+
+        let packet = packet.unwrap();
+        assert_eq!(
+            packet,
+            Packet::new(
+                PacketId::Event,
+                "on_abc_event".to_string(),
+                Some(
+                    serde_json::json!({
+                        "abc": 0,
+                        "some_other": "value",
+                    }).to_string()
+                ),
+                None,
+                0,
+                None,
+            )
+        );
+
+
         let cb = |message: Payload, _| {
             async {
                 println!("Yehaa! My ack got acked?");

diff --git a/socketio/src/client/raw_client.rs b/socketio/src/client/raw_client.rs
@@ -753,6 +753,29 @@ mod test {
             )
         );
 
+        let packet: Option<Packet> = iter.next();
+
+        assert!(packet.is_some());
+
+        let packet = packet.unwrap();
+        assert_eq!(
+            packet,
+            Packet::new(
+                PacketId::Event,
+                "on_abc_event".to_string(),
+                Some(
+                    serde_json::json!({
+                        "abc": 0,
+                        "some_other": "value",
+                    }).to_string()
+                ),
+                None,
+                0,
+                None,
+            )
+        );
+
+
         assert!(socket
             .emit_with_ack(
                 "test",