use super::*;
#[allow(dead_code)] // xxx
-#[throws(PacketError)]
-pub async fn run(_global: &Global,
- _rx: mpsc::Receiver<RoutedPacket>) {
-
+#[allow(unused_variables)] // xxx
+pub async fn run(global: Arc<Global>,
+ rx: mpsc::Receiver<RoutedPacket>,
+ mut ipif: Ipif) -> Result<Void,AE> {
+ let r = async {
+ loop {
+ select!{
+ data = ipif.tx.next_segment() =>
+ {
+ let data = data.context("read from ipif")?;
+ }
+ }
+ }
+ }.await;
+
+ ipif.quitting(None).await;
+ r
}