diff --git a/moq-demo-quinn/Cargo.toml b/moq-demo-quinn/Cargo.toml index eeca77d..2d9aee4 100644 --- a/moq-demo-quinn/Cargo.toml +++ b/moq-demo-quinn/Cargo.toml @@ -25,7 +25,7 @@ rustls = "0.21.2" rustls-pemfile = "1.0.2" # Async stuff -tokio = { version = "1.29.1", features = ["full"] } +tokio = { version = "1.27", features = ["full"] } # Web server to serve the fingerprint warp = { version = "0.3.3", features = ["tls"] } diff --git a/moq-demo-quinn/src/server/mod.rs b/moq-demo-quinn/src/server/mod.rs index b2a831a..0cb2b35 100644 --- a/moq-demo-quinn/src/server/mod.rs +++ b/moq-demo-quinn/src/server/mod.rs @@ -120,28 +120,6 @@ impl Server { } } - // pub async fn run(mut self) -> anyhow::Result<()> { - // loop { - // tokio::select! { - // res = self.server.accept() => { - // let session = res.context("failed to accept connection")?; - // let broker = self.broker.clone(); - - // self.tasks.spawn(async move { - // let session: Session = Session::accept(session, broker).await?; - // session.run().await - // }); - // }, - // res = self.tasks.join_next(), if !self.tasks.is_empty() => { - // let res = res.expect("no tasks").expect("task aborted"); - - // if let Err(err) = res { - // log::error!("session terminated: {:?}", err); - // } - // }, - // } - // } - // } } // The WebTransport CONNECT has arrived, and we need to decide if we accept it.