feat: Fix tokio

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "rakrs"
-version = "0.3.0-rc.3"
+version = "0.3.0-rc.4"
 authors = ["Bavfalcon9 <olybear9@gmail.com>"]
 edition = "2021"
 

src/connection/mod.rs

@@ -30,6 +30,11 @@ use tokio::{
     task::{self, JoinHandle},
     time::sleep,
 };
+#[cfg(feature = "async_tokio")]
+pub enum RecvError {
+    Closed,
+    Timeout,
+}
 
 use crate::{
     protocol::{
@@ -234,7 +239,7 @@ impl Connection {
     ///
     pub async fn init_net_recv(
         &self,
-        net: Receiver<Vec<u8>>,
+        mut net: Receiver<Vec<u8>>,
         sender: Sender<Vec<u8>>,
     ) -> task::JoinHandle<()> {
         let recv_time = self.recv_time.clone();
@@ -471,10 +476,17 @@ impl Connection {
 
     /// Recieve a packet from the client.
     pub async fn recv(&mut self) -> Result<Vec<u8>, RecvError> {
-        let q = self.internal_net_recv.as_ref().lock().await;
+        #[allow(unused_mut)]
+        let mut q = self.internal_net_recv.as_ref().lock().await;
         match q.recv().await {
+            #[cfg(feature = "async_std")]
             Ok(packet) => Ok(packet),
+            #[cfg(feature = "async_std")]
             Err(e) => Err(e),
+            #[cfg(feature = "async_tokio")]
+            Some(packet) => Ok(packet),
+            #[cfg(feature = "async_tokio")]
+            None => Err(RecvError::Closed),
         }
     }
 

src/connection/queue/recv.rs

@@ -25,7 +25,6 @@ pub struct RecvQueue {
     /// (seq, time)
     ack: HashSet<(u32, u64)>,
     nack: HashSet<u32>,
-    highest_seq: u32,
     ready: Vec<Vec<u8>>,
 }
 
@@ -37,7 +36,6 @@ impl RecvQueue {
             nack: HashSet::new(),
             window: ReliableWindow::new(),
             reliable_window: ReliableWindow::new(),
-            highest_seq: 0,
             ready: Vec::new(),
             order_channels: HashMap::new(),
         }