update rand v0.9.x

Cargo.toml

@@ -28,7 +28,7 @@ thiserror = "1"
 futures = "0.3"
 async-trait = "0.1"
 parking_lot = "0.12"
-rand = "0.8"
+rand = "0.9"
 bytes = "1"
 tokio = { version = "1", features = ["full"], optional = true }
 tokio-util = { version = "0.7", features = ["compat"], optional = true }

examples/stock_server.rs

@@ -6,7 +6,7 @@ use zeromq::*;
 
 #[async_helpers::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
-    let mut rng = rand::thread_rng();
+    let mut rng = rand::rng();
     let stocks: Vec<&str> = vec!["AAA", "ABB", "BBB"];
     println!("Starting server");
     let mut socket = zeromq::PubSocket::new();
@@ -15,7 +15,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     println!("Start sending loop");
     loop {
         for stock in &stocks {
-            let price: u32 = rng.gen_range(1..100);
+            let price: u32 = rng.random_range(1..100);
             let mut m: ZmqMessage = ZmqMessage::from(*stock);
             m.push_back(price.to_ne_bytes().to_vec().into());
             println!("Sending: {:?}", m);

examples/task_ventilator.rs

@@ -26,10 +26,10 @@ async fn main() -> Result<(), Box<dyn Error>> {
     // The first message is "0" and signals start of batch
     sink.send("0".into()).await?;
 
-    let mut rnd = rand::thread_rng();
+    let mut rnd = rand::rng();
     let mut total_msec = 0;
     for _ in 0..100 {
-        let workload = rnd.gen_range(1..100);
+        let workload = rnd.random_range(1..100);
         sender.send(workload.to_string().into()).await?;
         total_msec += workload;
     }

examples/weather_server.rs

@@ -7,16 +7,16 @@ use zeromq::*;
 
 #[async_helpers::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
-    let mut rng = rand::thread_rng();
+    let mut rng = rand::rng();
     println!("Start server");
     let mut socket = zeromq::PubSocket::new();
     socket.bind("tcp://127.0.0.1:5556").await?;
 
     println!("Start sending loop");
     loop {
-        let zipcode = rng.gen_range(10000..10010);
-        let temperature = rng.gen_range(-80..135);
-        let relhumidity = rng.gen_range(10..60);
+        let zipcode = rng.random_range(10000..10010);
+        let temperature = rng.random_range(-80..135);
+        let relhumidity = rng.random_range(10..60);
         socket
             .send(format!("{} {} {}", zipcode, temperature, relhumidity).into())
             .await?;

src/util.rs

@@ -211,8 +211,9 @@ pub(crate) async fn connect_forever(endpoint: Endpoint) -> ZmqResult<(FramedIo,
                     try_num += 1;
                 }
                 let delay = {
-                    let mut rng = rand::thread_rng();
-                    std::f64::consts::E.powf(try_num as f64 / 3.0) + rng.gen_range(0.0f64..0.1f64)
+                    let mut rng = rand::rng();
+                    std::f64::consts::E.powf(try_num as f64 / 3.0)
+                        + rng.random_range(0.0f64..0.1f64)
                 };
                 async_rt::task::sleep(std::time::Duration::from_secs_f64(delay)).await;
             }