update rand to 0.9, tungstenite to 0.26

Author: getong

Cargo.lock

@@ -31,7 +31,7 @@ crossbeam-utils = "0.8"
 log = "0.4"
 strum = { version = "0.24", features = ["derive"] }
 socket2 = { version = "0.5.1", features = ["all"], optional = true}
-tungstenite = { version = "0.22.0", features = ["url"], optional = true }
+tungstenite = { version = "0.26", features = ["url"], optional = true }
 url = { version = "2.2", optional = true }
 integer-encoding = "3.0.2"
 lazy_static = "1.4.0"
@@ -51,7 +51,7 @@ criterion = "0.4"
 fern = "0.6.0"
 chrono = { version = "0.4.24", features = ["clock"], default-features = false }
 test-case = "1.1.0"
-rand = "0.8"
+rand = "0.9"
 httparse = "1.3.5"
 doc-comment = "0.3"
 

Cargo.toml

@@ -234,7 +234,7 @@ fn throughput_native_ws(packet_size: usize) {
                 let (mut sender, _) = ws_connect(Url::parse(&url_addr).unwrap()).unwrap();
                 let start_time = Instant::now();
                 while total_sent < EXPECTED_BYTES {
-                    sender.send(Message::Binary(message.clone())).unwrap();
+                    sender.send(Message::Binary(message.clone().into())).unwrap();
                     total_sent += message.len();
                 }
                 start_time

examples/throughput/main.rs

@@ -162,7 +162,7 @@ impl Remote for RemoteResource {
         let deref_state = state.deref_mut();
         match deref_state {
             RemoteState::WebSocket(web_socket) => {
-                let message = Message::Binary(data.to_vec());
+                let message = Message::Binary(data.to_vec().into());
 
                 let mut result = web_socket.send(message);
                 loop {

src/adapters/ws.rs

@@ -287,7 +287,7 @@ fn message_size(transport: Transport, message_size: usize) {
     assert!(message_size <= transport.max_message_size());
 
     let mut rng = rand::rngs::StdRng::seed_from_u64(42);
-    let sent_message: Vec<u8> = (0..message_size).map(|_| rng.gen()).collect();
+    let sent_message: Vec<u8> = (0..message_size).map(|_| rng.random()).collect();
 
     let (node, listener) = node::split();
     node.signals().send_with_timer((), *TIMEOUT);