chore: callback demo lock conflict

1c3t3a · Aug 10, 2022 · 2b240c6 · 2b240c6
1 parent d709f6c
commit 2b240c6
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/socketio/examples/callback.rs b/socketio/examples/callback.rs
@@ -44,5 +44,14 @@ fn main() {
 
     // use the socket
 
-    socket.disconnect().expect("Disconnect failed")
+    let join_handle = std::thread::spawn(move || loop {
+        println!("{:?} will emit", std::time::Instant::now());
+        let r = socket.emit("message", json!("test"));
+        println!("{:?} did emit {:?} ", std::time::Instant::now(), r);
+        std::thread::sleep(std::time::Duration::from_millis(10));
+    });
+
+    let _ = join_handle.join();
+
+    // socket.disconnect().expect("Disconnect failed")
 }