voxel/kubi
1
1
Fork 0
mirror of https://github.com/griffi-gh/kubi.git synced 2024-12-24 21:08:19 -06:00
Code Issues Packages Projects Releases Wiki Activity

...

Browse source
This commit is contained in:
griffi-gh 2023-02-06 02:40:45 +01:00
parent 9eae5d780b
commit 2e66d0bda8
2 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
kubi-udp/src/client.rs
View file

@ -3,7 +3,7 @@ use std::{
net::{UdpSocket, SocketAddr}, net::{UdpSocket, SocketAddr},
time::{Instant, Duration}, time::{Instant, Duration},
marker::PhantomData, marker::PhantomData,
collections::{VecDeque, vec_deque::Drain}, collections::VecDeque,
}; };
use bincode::{Encode, Decode}; use bincode::{Encode, Decode};
use crate::{ use crate::{
@ -169,7 +169,7 @@ impl<S, R> Client<S, R> where S: Encode + Decode, R: Encode + Decode {
pub fn get_event(&mut self) -> Option<ClientEvent<R>> { pub fn get_event(&mut self) -> Option<ClientEvent<R>> {
self.event_queue.pop_front() self.event_queue.pop_front()
} }
pub fn process_events(&mut self) -> Drain<ClientEvent<R>> { pub fn process_events(&mut self) -> impl Iterator<Item = ClientEvent<R>> + '_ {
self.event_queue.drain(..) self.event_queue.drain(..)
} }
} }

6
kubi-udp/src/server.rs
View file

@ -23,4 +23,10 @@ impl Server {
clients: HashMap::with_capacity_and_hasher(MAX_CLIENTS, BuildNoHashHasher::default()) clients: HashMap::with_capacity_and_hasher(MAX_CLIENTS, BuildNoHashHasher::default())
}) })
} }
pub fn update(&mut self) {
let mut buf = Vec::new();
if self.socket.recv(&mut buf).is_ok() {
todo!()
}
}
} }