summaryrefslogtreecommitdiff
path: root/client/src/network.rs
diff options
context:
space:
mode:
authormetamuffin <metamuffin@disroot.org>2025-01-06 14:28:02 +0100
committermetamuffin <metamuffin@disroot.org>2025-01-06 14:28:02 +0100
commit814cc1cb01692aa934a40636c9226ff7bb911266 (patch)
tree47a50a5dc1861ace4bc1854a9156618b70df3847 /client/src/network.rs
parentc2ee65a83838a0ce13402e2c4634bae409d55071 (diff)
downloadweareserver-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.rs6
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(())