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

inline client functions

Browse source
This commit is contained in:
griffi-gh 2023-02-12 21:42:29 +01:00
parent 053c199f51
commit 125b870a8b
1 changed files with 13 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -63,6 +63,7 @@ pub struct Client<S, R> where S: Encode + Decode, R: Encode + Decode {
_s: PhantomData<S>, _s: PhantomData<S>,
} }
impl<S, R> Client<S, R> where S: Encode + Decode, R: Encode + Decode { impl<S, R> Client<S, R> where S: Encode + Decode, R: Encode + Decode {
#[inline]
pub fn new(addr: SocketAddr, config: ClientConfig) -> Result<Self> { pub fn new(addr: SocketAddr, config: ClientConfig) -> Result<Self> {
let bind_addr: SocketAddr = "0.0.0.0:0".parse().unwrap(); let bind_addr: SocketAddr = "0.0.0.0:0".parse().unwrap();
let socket = UdpSocket::bind(bind_addr)?; let socket = UdpSocket::bind(bind_addr)?;
@ -103,7 +104,7 @@ impl<S, R> Client<S, R> where S: Encode + Decode, R: Encode + Decode {
self.timeout = Instant::now(); self.timeout = Instant::now();
} }
#[inline]
pub fn connect(&mut self) -> Result<()> { pub fn connect(&mut self) -> Result<()> {
log::info!("client connect called"); log::info!("client connect called");
if self.status != ClientStatus::Disconnected { if self.status != ClientStatus::Disconnected {
@ -117,6 +118,7 @@ impl<S, R> Client<S, R> where S: Encode + Decode, R: Encode + Decode {
Ok(()) Ok(())
} }
#[inline]
pub fn disconnect(&mut self) -> Result<()> { pub fn disconnect(&mut self) -> Result<()> {
if self.status != ClientStatus::Connected { if self.status != ClientStatus::Connected {
bail!("Not Connected"); bail!("Not Connected");
@ -125,28 +127,34 @@ impl<S, R> Client<S, R> where S: Encode + Decode, R: Encode + Decode {
Ok(()) Ok(())
} }
#[inline]
pub fn get_status(&self) -> ClientStatus { pub fn get_status(&self) -> ClientStatus {
self.status self.status
} }
#[inline]
pub fn is_connected(&self) -> bool { pub fn is_connected(&self) -> bool {
self.status == ClientStatus::Connected self.status == ClientStatus::Connected
} }
#[inline]
pub fn is_connecting(&self) -> bool { pub fn is_connecting(&self) -> bool {
self.status == ClientStatus::Connecting self.status == ClientStatus::Connecting
} }
#[inline]
pub fn is_disconnected(&self) -> bool { pub fn is_disconnected(&self) -> bool {
self.status == ClientStatus::Disconnected self.status == ClientStatus::Disconnected
} }
//Return true if the client has not made any connection attempts yet //Return true if the client has not made any connection attempts yet
#[inline]
pub fn has_not_made_connection_attempts(&self) -> bool { pub fn has_not_made_connection_attempts(&self) -> bool {
matches!(self.status, ClientStatus::Disconnected) && matches!(self.status, ClientStatus::Disconnected) &&
matches!(self.disconnect_reason, DisconnectReason::NotConnected) matches!(self.disconnect_reason, DisconnectReason::NotConnected)
} }
#[inline]
pub fn send_message(&self, message: S) -> Result<()> { pub fn send_message(&self, message: S) -> Result<()> {
if self.status != ClientStatus::Connected { if self.status != ClientStatus::Connected {
bail!("Not Connected"); bail!("Not Connected");
@ -155,6 +163,7 @@ impl<S, R> Client<S, R> where S: Encode + Decode, R: Encode + Decode {
Ok(()) Ok(())
} }
#[inline]
pub fn update(&mut self) -> Result<()> { // , callback: fn(ClientEvent<R>) -> Result<()> pub fn update(&mut self) -> Result<()> { // , callback: fn(ClientEvent<R>) -> Result<()>
if self.status == ClientStatus::Disconnected { if self.status == ClientStatus::Disconnected {
return Ok(()) return Ok(())
@ -212,9 +221,12 @@ impl<S, R> Client<S, R> where S: Encode + Decode, R: Encode + Decode {
Ok(()) Ok(())
} }
#[inline]
pub fn pop_event(&mut self) -> Option<ClientEvent<R>> { pub fn pop_event(&mut self) -> Option<ClientEvent<R>> {
self.event_queue.pop_front() self.event_queue.pop_front()
} }
#[inline]
pub fn process_events(&mut self) -> DrainDeque<ClientEvent<R>> { pub fn process_events(&mut self) -> DrainDeque<ClientEvent<R>> {
self.event_queue.drain(..) self.event_queue.drain(..)
} }