diff options
author | metamuffin <metamuffin@disroot.org> | 2025-01-06 14:28:02 +0100 |
---|---|---|
committer | metamuffin <metamuffin@disroot.org> | 2025-01-06 14:28:02 +0100 |
commit | 814cc1cb01692aa934a40636c9226ff7bb911266 (patch) | |
tree | 47a50a5dc1861ace4bc1854a9156618b70df3847 /client/src/network.rs | |
parent | c2ee65a83838a0ce13402e2c4634bae409d55071 (diff) | |
download | weareserver-814cc1cb01692aa934a40636c9226ff7bb911266.tar weareserver-814cc1cb01692aa934a40636c9226ff7bb911266.tar.bz2 weareserver-814cc1cb01692aa934a40636c9226ff7bb911266.tar.zst |
new proto
Diffstat (limited to 'client/src/network.rs')
-rw-r--r-- | client/src/network.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/client/src/network.rs b/client/src/network.rs index e542c7e..e54ecf7 100644 --- a/client/src/network.rs +++ b/client/src/network.rs @@ -7,7 +7,7 @@ use std::{ use anyhow::Result; use log::{debug, info, warn}; -use weareshared::packets::Packet; +use weareshared::packets::{Packet, ReadWrite}; pub struct Network { pub packet_recv: Receiver<Packet>, @@ -40,7 +40,7 @@ impl Network { fn handle_conn_read(sock: TcpStream, tx: Sender<Packet>) -> Result<()> { let mut sock = BufReader::new(sock); loop { - let packet = Packet::deserialize(&mut sock)?; + let packet = Packet::read(&mut sock)?; debug!("<- {packet:?}"); tx.send(packet)?; } @@ -49,7 +49,7 @@ fn handle_conn_write(sock: TcpStream, rx: Receiver<Packet>) -> Result<()> { let mut sock = BufWriter::new(sock); for packet in rx { debug!("-> {packet:?}"); - packet.serialize(&mut sock)?; + packet.write(&mut sock)?; sock.flush()?; } Ok(()) |