aboutsummaryrefslogtreecommitdiff
path: root/crates/whirl_server/src/distributor.rs
diff options
context:
space:
mode:
authorFuwn <[email protected]>2024-06-03 14:57:47 -0700
committerFuwn <[email protected]>2024-06-03 14:57:47 -0700
commita6b766541ae58053ae705e0559d1a1ae8212634b (patch)
treeaeb55206e77679b2f5e1f47fae7f1bda5c6df5b9 /crates/whirl_server/src/distributor.rs
parentMerge pull request #153 from Whirlsplash/renovate/actions-checkout-3.x (diff)
downloadwhirl-old.tar.xz
whirl-old.zip
fix: bump rust and update accordinglyold
Diffstat (limited to 'crates/whirl_server/src/distributor.rs')
-rw-r--r--crates/whirl_server/src/distributor.rs5
1 files changed, 2 insertions, 3 deletions
diff --git a/crates/whirl_server/src/distributor.rs b/crates/whirl_server/src/distributor.rs
index 3d684ff..1213090 100644
--- a/crates/whirl_server/src/distributor.rs
+++ b/crates/whirl_server/src/distributor.rs
@@ -13,7 +13,6 @@
use std::{error::Error, net::SocketAddr, sync::Arc};
-use num_traits::cast::AsPrimitive;
use tokio::{io::AsyncWriteExt, net::TcpStream, sync::Mutex};
use tokio_stream::StreamExt;
use tokio_util::codec::{BytesCodec, Decoder};
@@ -66,7 +65,7 @@ impl Server for Distributor {
result = peer.bytes.next() => match result {
Some(Ok(msg)) => {
for msg in parse_commands_from_packet(msg) {
- match num_traits::FromPrimitive::from_i32(msg.get(2).unwrap().to_owned().as_(): i32) {
+ match num_traits::FromPrimitive::from_i32(msg.get(2).unwrap().to_owned() as i32) {
Some(Command::PropReq) => {
debug!("received property request from client");
@@ -120,7 +119,7 @@ impl Server for Distributor {
peer.bytes.get_mut().write_all(&RedirectId {
room_name: (&*room.room_name).to_string(),
- room_number: room_id.as_(): i8,
+ room_number: room_id as i8,
}.create()).await?;
trace!("sent redirect id to {}: {}", username, room.room_name);
}