Skip to content

Commit acf1093

Browse files
authored
fix(test): concurrent_emti
1 parent a2b974b commit acf1093

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

socketioxide/tests/concurrent_emit.rs

+4-2
Original file line numberDiff line numberDiff line change
@@ -19,12 +19,14 @@ pub async fn emit() {
1919
use Message::*;
2020
let io = create_server(PORT).await;
2121

22+
let io2 = io.clone();
23+
2224
io.ns("/", move |socket: SocketRef| async move {
2325
for _ in 0..100 {
24-
let s = socket.clone();
26+
let io = io2.clone();
2527
tokio::task::spawn_blocking(move || {
2628
for _ in 0..100 {
27-
s.bin(vec![vec![1, 2, 3], vec![4, 5, 6]])
29+
io.bin(vec![vec![1, 2, 3], vec![4, 5, 6]])
2830
.emit("test", "bin")
2931
.unwrap();
3032
}

0 commit comments

Comments
 (0)