diff --git a/Cargo.toml b/Cargo.toml index f5446c6629..d6bd75c244 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -121,7 +121,6 @@ checked_conversions = "allow" else_if_without_else = "allow" enum_glob_use = "allow" float_arithmetic = "allow" -ignored_unit_patterns = "allow" indexing_slicing = "allow" integer_division = "allow" integer_division_remainder_used = "allow" diff --git a/src/client/dispatch.rs b/src/client/dispatch.rs index a9375f627a..0d91a1d92e 100644 --- a/src/client/dispatch.rs +++ b/src/client/dispatch.rs @@ -111,7 +111,7 @@ impl Sender { let (tx, rx) = oneshot::channel(); self.inner .send(Envelope(Some((val, Callback::Retry(Some(tx)))))) - .map(move |_| rx) + .map(move |()| rx) .map_err(|mut e| (e.0).0.take().expect("envelope not dropped").0) } @@ -123,7 +123,7 @@ impl Sender { let (tx, rx) = oneshot::channel(); self.inner .send(Envelope(Some((val, Callback::NoRetry(Some(tx)))))) - .map(move |_| rx) + .map(move |()| rx) .map_err(|mut e| (e.0).0.take().expect("envelope not dropped").0) } @@ -150,7 +150,7 @@ impl UnboundedSender { let (tx, rx) = oneshot::channel(); self.inner .send(Envelope(Some((val, Callback::Retry(Some(tx)))))) - .map(move |_| rx) + .map(move |()| rx) .map_err(|mut e| (e.0).0.take().expect("envelope not dropped").0) } @@ -158,7 +158,7 @@ impl UnboundedSender { let (tx, rx) = oneshot::channel(); self.inner .send(Envelope(Some((val, Callback::NoRetry(Some(tx)))))) - .map(move |_| rx) + .map(move |()| rx) .map_err(|mut e| (e.0).0.take().expect("envelope not dropped").0) } } diff --git a/src/proto/h1/io.rs b/src/proto/h1/io.rs index b49e48e5c8..386f1be35b 100644 --- a/src/proto/h1/io.rs +++ b/src/proto/h1/io.rs @@ -240,7 +240,7 @@ where let dst = unsafe { self.read_buf.chunk_mut().as_uninit_slice_mut() }; let mut buf = ReadBuf::uninit(dst); match Pin::new(&mut self.io).poll_read(cx, buf.unfilled()) { - Poll::Ready(Ok(_)) => { + Poll::Ready(Ok(())) => { let n = buf.filled().len(); trace!("received {} bytes", n); // Safety: we just read that many bytes into the