feat(api): simplify polling

hussein-aitlahcen · Oct 27, 2022 · af05ae8 · af05ae8
1 parent 2f97690
commit af05ae8
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 12 deletions.
diff --git a/example/src/main.rs b/example/src/main.rs
@@ -88,7 +88,7 @@ fn server(port: u16) {
         };
 
         // Process connections events.
-        let _events_processed = server.poll_event::<100, _>(|event| {
+        let _events_processed = server.poll_event::<100>(|event| {
           match (event.old_state(), event.info().state()) {
             // A client is about to connect, accept it.
             (
@@ -141,7 +141,7 @@ fn server(port: u16) {
         });
 
         // Process some messages, we arbitrary define 100 as being the max number of messages we can handle per iteration.
-        let _messages_processed = server.poll_messages::<100, _>(|message| {
+        let _messages_processed = server.poll_messages::<100>(|message| {
             // **unwrap** must be banned in production.
             let chat_message = core::str::from_utf8(message.payload()).unwrap();
             println!("Boarcasting {}", chat_message);
@@ -196,7 +196,7 @@ fn client(port: u16) {
         client.poll_callbacks();
 
         // Process some messages, we arbitrary define 100 as being the max number of messages we can handle per iteration.
-        let _messages_processed = client.poll_messages::<100, _>(|message| {
+        let _messages_processed = client.poll_messages::<100>(|message| {
             println!(
                 "(Chat) {}",
                 // **unwrap** must be banned in production.
@@ -206,7 +206,7 @@ fn client(port: u16) {
 
         let mut quit = false;
         let _ =
-            client.poll_event::<100, _>(|event| match (event.old_state(), event.info().state()) {
+            client.poll_event::<100>(|event| match (event.old_state(), event.info().state()) {
                 (
                     ESteamNetworkingConnectionState::k_ESteamNetworkingConnectionState_None,
                     ESteamNetworkingConnectionState::k_ESteamNetworkingConnectionState_Connecting,

diff --git a/gns/src/lib.rs b/gns/src/lib.rs
@@ -676,10 +676,10 @@ where
     }
 
     #[inline]
-    pub fn poll_messages<const K: usize, F>(&self, mut message_callback: F) -> Option<usize>
-    where
-        F: FnMut(&GnsNetworkMessage<ToReceive>),
-    {
+    pub fn poll_messages<const K: usize>(
+        &self,
+        mut message_callback: impl FnMut(&GnsNetworkMessage<ToReceive>),
+    ) -> Option<usize> {
         // Do not implements default for networking messages as they must be allocated by the lib.
         let mut messages: [GnsNetworkMessage<ToReceive>; K] =
             unsafe { MaybeUninit::zeroed().assume_init() };
@@ -695,10 +695,10 @@ where
     }
 
     #[inline]
-    pub fn poll_event<const K: usize, F>(&self, mut event_callback: F) -> usize
-    where
-        F: FnMut(GnsConnectionEvent),
-    {
+    pub fn poll_event<const K: usize>(
+        &self,
+        mut event_callback: impl FnMut(GnsConnectionEvent),
+    ) -> usize {
         let mut processed = 0;
         'a: while let Some(event) = self.state.queue().pop() {
             event_callback(event);