|
1 | 1 | use std::{collections::HashMap, fmt::Write, io, sync::Arc}; |
2 | 2 |
|
3 | 3 | use futures_util::{stream::FuturesUnordered, StreamExt, TryFutureExt, TryStreamExt}; |
4 | | -use rand::{rngs::SmallRng, thread_rng, Rng, SeedableRng}; |
| 4 | +use rand::{rng, rngs::SmallRng, Rng, SeedableRng}; |
5 | 5 | use tokio::pin; |
6 | 6 | use tokio_postgres::{connect, types::ToSql, Client, NoTls, Statement}; |
7 | 7 | use viz::{Error, IntoResponse, Response, StatusCode}; |
@@ -105,33 +105,33 @@ impl PgConnection { |
105 | 105 | } |
106 | 106 |
|
107 | 107 | pub async fn get_world(&self) -> Result<World, PgError> { |
108 | | - let mut rng = SmallRng::from_rng(&mut thread_rng()).unwrap(); |
109 | | - let random_id = (rng.gen::<u32>() % 10_000 + 1) as i32; |
| 108 | + let mut rng = SmallRng::from_rng(&mut rng()); |
| 109 | + let random_id = (rng.random::<u32>() % 10_000 + 1) as i32; |
110 | 110 |
|
111 | 111 | self.query_one_world(random_id).await |
112 | 112 | } |
113 | 113 |
|
114 | 114 | pub async fn get_worlds(&self, num: u16) -> Result<Vec<World>, PgError> { |
115 | | - let mut rng = SmallRng::from_rng(&mut thread_rng()).unwrap(); |
| 115 | + let mut rng = SmallRng::from_rng(&mut rng()); |
116 | 116 |
|
117 | 117 | let worlds = FuturesUnordered::new(); |
118 | 118 |
|
119 | 119 | for _ in 0..num { |
120 | | - let id = (rng.gen::<u32>() % 10_000 + 1) as i32; |
| 120 | + let id = (rng.random::<u32>() % 10_000 + 1) as i32; |
121 | 121 | worlds.push(self.query_one_world(id)); |
122 | 122 | } |
123 | 123 |
|
124 | 124 | worlds.try_collect().await |
125 | 125 | } |
126 | 126 |
|
127 | 127 | pub async fn update(&self, num: u16) -> Result<Vec<World>, PgError> { |
128 | | - let mut rng = SmallRng::from_rng(&mut thread_rng()).unwrap(); |
| 128 | + let mut rng = SmallRng::from_rng(&mut rng()); |
129 | 129 |
|
130 | 130 | let worlds = FuturesUnordered::new(); |
131 | 131 |
|
132 | 132 | for _ in 0..num { |
133 | | - let id = (rng.gen::<u32>() % 10_000 + 1) as i32; |
134 | | - let rid = (rng.gen::<u32>() % 10_000 + 1) as i32; |
| 133 | + let id = (rng.random::<u32>() % 10_000 + 1) as i32; |
| 134 | + let rid = (rng.random::<u32>() % 10_000 + 1) as i32; |
135 | 135 |
|
136 | 136 | worlds.push(self.query_one_world(id).map_ok(move |mut world| { |
137 | 137 | world.randomnumber = rid; |
|
0 commit comments