Clean up warnings/errors

quinn-rs · Sep 3, 2020 · f212256 · f212256
1 parent 35db51e
commit f212256
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 8 deletions.
diff --git a/quinn/examples/server.rs b/quinn/examples/server.rs
@@ -137,11 +137,9 @@ async fn run(options: Opt) -> Result<()> {
         bail!("root path does not exist");
     }
 
-    let mut incoming = {
-        let (endpoint, incoming) = endpoint.bind(&options.listen)?;
-        info!("listening on {}", endpoint.local_addr()?);
-        incoming
-    };
+    let (endpoint, mut incoming) = endpoint.bind(&options.listen)?;
+    info!("listening on {}", endpoint.local_addr()?);
+    drop(endpoint);
 
     while let Some(conn) = incoming.next().await {
         info!("connection incoming");

diff --git a/quinn/src/connection.rs b/quinn/src/connection.rs
@@ -255,7 +255,7 @@ where
     S: proto::crypto::Session,
 {
     type Output = ();
-    fn poll(mut self: Pin<&mut Self>, cx: &mut Context) -> Poll<Self::Output> {
+    fn poll(self: Pin<&mut Self>, cx: &mut Context) -> Poll<Self::Output> {
         let conn = &mut *self.0.lock().unwrap();
 
         let span = info_span!("drive", id = conn.handle.0);

diff --git a/quinn/src/endpoint.rs b/quinn/src/endpoint.rs
@@ -184,7 +184,7 @@ where
     S: proto::crypto::Session + 'static,
 {
     type Output = Result<(), io::Error>;
-    fn poll(mut self: Pin<&mut Self>, cx: &mut Context) -> Poll<Self::Output> {
+    fn poll(self: Pin<&mut Self>, cx: &mut Context) -> Poll<Self::Output> {
         let endpoint = &mut *self.0.lock().unwrap();
         if endpoint.driver.is_none() {
             endpoint.driver = Some(cx.waker().clone());
@@ -410,7 +410,7 @@ where
     S: proto::crypto::Session,
 {
     type Item = Connecting<S>;
-    fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context) -> Poll<Option<Self::Item>> {
+    fn poll_next(self: Pin<&mut Self>, cx: &mut Context) -> Poll<Option<Self::Item>> {
         let endpoint = &mut *self.0.lock().unwrap();
         if endpoint.driver_lost {
             Poll::Ready(None)