update deps

Author: VendettaReborn

Cargo.lock

@@ -30,7 +30,7 @@ socket2-ext = { version = "0.1" }
 
 netstack-smoltcp = { git = "https://github.com/automesh-network/netstack-smoltcp.git", rev = "62260478079d96b42fa524caa855609312c2cf43" }
 netstack-lwip = { git = "https://github.com/Watfaq/netstack-lwip.git", rev = "2817bf82740e04bbee6b7bf1165f55657a6ed163" }
-netstack-system = { git = "https://github.com/Watfaq/netstack-system.git", rev = "d8ffc602137cd826c6bf426432f07a1725c6d33f" }
+netstack-system = { git = "https://github.com/Watfaq/netstack-system.git", rev = "73373ff" }
 
 [[bin]]
 name = "netstack-smoltcp"

Cargo.toml

@@ -88,7 +88,7 @@ async fn main_exec(opt: Opt) {
     println!("created device: {:?}", device.address());
 
     let framed = device.into_framed();
-    let (tun_sink, mut tun_stream) = framed.split();
+    let (mut tun_sink, mut tun_stream) = framed.split();
 
     let mut futs = vec![];
 
@@ -99,7 +99,12 @@ async fn main_exec(opt: Opt) {
     let listener = listener.unwrap();
     let udp_socket = udp_socket.unwrap();
 
-    futs.push(stack.process_loop(tun_sink));
+    futs.push(tokio_spawn!(async move {
+        let mut stream = Box::pin(stack.stream());
+        while let Some(pkt) = stream.next().await {
+            let _ = tun_sink.send(pkt).await;
+        }
+    }));
 
     futs.push(tokio_spawn!(async move {
         while let Some(pkt) = tun_stream.next().await {