restore tokio version and remove unneeded comments fin moq-demo-quinn
This commit is contained in:
parent
6ba26c8a16
commit
6212dc5e2f
|
@ -25,7 +25,7 @@ rustls = "0.21.2"
|
||||||
rustls-pemfile = "1.0.2"
|
rustls-pemfile = "1.0.2"
|
||||||
|
|
||||||
# Async stuff
|
# Async stuff
|
||||||
tokio = { version = "1.29.1", features = ["full"] }
|
tokio = { version = "1.27", features = ["full"] }
|
||||||
|
|
||||||
# Web server to serve the fingerprint
|
# Web server to serve the fingerprint
|
||||||
warp = { version = "0.3.3", features = ["tls"] }
|
warp = { version = "0.3.3", features = ["tls"] }
|
||||||
|
|
|
@ -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.
|
// The WebTransport CONNECT has arrived, and we need to decide if we accept it.
|
||||||
|
|
Loading…
Reference in New Issue