diff options
-rw-r--r-- | tokio-macros/src/lib.rs | 1 | ||||
-rw-r--r-- | tokio-util/src/lib.rs | 1 | ||||
-rw-r--r-- | tokio/src/lib.rs | 2 | ||||
-rw-r--r-- | tokio/src/stream/iter.rs | 6 | ||||
-rw-r--r-- | tokio/src/stream/map.rs | 22 | ||||
-rw-r--r-- | tokio/src/stream/mod.rs | 2 | ||||
-rw-r--r-- | tokio/src/stream/next.rs | 5 | ||||
-rw-r--r-- | tokio/tests/rt_basic.rs | 2 | ||||
-rw-r--r-- | tokio/tests/sync_broadcast.rs | 1 | ||||
-rw-r--r-- | tokio/tests/task_local_set.rs | 2 |
10 files changed, 22 insertions, 22 deletions
diff --git a/tokio-macros/src/lib.rs b/tokio-macros/src/lib.rs index 58092ed9..1116735a 100644 --- a/tokio-macros/src/lib.rs +++ b/tokio-macros/src/lib.rs @@ -1,4 +1,5 @@ #![doc(html_root_url = "https://docs.rs/tokio-macros/0.2.1")] +#![allow(clippy::needless_doctest_main)] #![warn( missing_debug_implementations, missing_docs, diff --git a/tokio-util/src/lib.rs b/tokio-util/src/lib.rs index 4cb54dfb..48c0fd16 100644 --- a/tokio-util/src/lib.rs +++ b/tokio-util/src/lib.rs @@ -1,4 +1,5 @@ #![doc(html_root_url = "https://docs.rs/tokio-util/0.2.0")] +#![allow(clippy::needless_doctest_main)] #![warn( missing_debug_implementations, missing_docs, diff --git a/tokio/src/lib.rs b/tokio/src/lib.rs index 23f5862f..b11600b4 100644 --- a/tokio/src/lib.rs +++ b/tokio/src/lib.rs @@ -1,5 +1,5 @@ #![doc(html_root_url = "https://docs.rs/tokio/0.2.6")] -#![allow(clippy::cognitive_complexity)] +#![allow(clippy::cognitive_complexity, clippy::needless_doctest_main)] #![warn( missing_debug_implementations, missing_docs, diff --git a/tokio/src/stream/iter.rs b/tokio/src/stream/iter.rs index dc06495e..5909b4cf 100644 --- a/tokio/src/stream/iter.rs +++ b/tokio/src/stream/iter.rs @@ -30,7 +30,8 @@ impl<I> Unpin for Iter<I> {} /// # } /// ``` pub fn iter<I>(i: I) -> Iter<I::IntoIter> - where I: IntoIterator, +where + I: IntoIterator, { Iter { iter: i.into_iter(), @@ -38,7 +39,8 @@ pub fn iter<I>(i: I) -> Iter<I::IntoIter> } impl<I> Stream for Iter<I> - where I: Iterator, +where + I: Iterator, { type Item = I::Item; diff --git a/tokio/src/stream/map.rs b/tokio/src/stream/map.rs index a89769de..cc0c84e0 100644 --- a/tokio/src/stream/map.rs +++ b/tokio/src/stream/map.rs @@ -20,15 +20,14 @@ where St: fmt::Debug, { fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { - f.debug_struct("Map") - .field("stream", &self.stream) - .finish() + f.debug_struct("Map").field("stream", &self.stream).finish() } } impl<St, T, F> Map<St, F> - where St: Stream, - F: FnMut(St::Item) -> T, +where + St: Stream, + F: FnMut(St::Item) -> T, { pub(super) fn new(stream: St, f: F) -> Map<St, F> { Map { stream, f } @@ -36,17 +35,16 @@ impl<St, T, F> Map<St, F> } impl<St, F, T> Stream for Map<St, F> - where St: Stream, - F: FnMut(St::Item) -> T, +where + St: Stream, + F: FnMut(St::Item) -> T, { type Item = T; - fn poll_next( - mut self: Pin<&mut Self>, - cx: &mut Context<'_>, - ) -> Poll<Option<T>> { + fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<T>> { self.as_mut() - .project().stream + .project() + .stream .poll_next(cx) .map(|opt| opt.map(|x| (self.as_mut().project().f)(x))) } diff --git a/tokio/src/stream/mod.rs b/tokio/src/stream/mod.rs index 04e6dc06..2d48bc7e 100644 --- a/tokio/src/stream/mod.rs +++ b/tokio/src/stream/mod.rs @@ -1,6 +1,6 @@ //! Stream utilities for Tokio. //! -//! `Stream`s are an asynchoronous version of standard library's Iterator. +//! A `Stream` is an asynchronous sequence of values. It can be thought of as an asynchronous version of the standard library's `Iterator` trait. //! //! This module provides helpers to work with them. diff --git a/tokio/src/stream/next.rs b/tokio/src/stream/next.rs index 3b0a1dd8..5139fbea 100644 --- a/tokio/src/stream/next.rs +++ b/tokio/src/stream/next.rs @@ -22,10 +22,7 @@ impl<'a, St: ?Sized + Stream + Unpin> Next<'a, St> { impl<St: ?Sized + Stream + Unpin> Future for Next<'_, St> { type Output = Option<St::Item>; - fn poll( - mut self: Pin<&mut Self>, - cx: &mut Context<'_>, - ) -> Poll<Self::Output> { + fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { Pin::new(&mut self.stream).poll_next(cx) } } diff --git a/tokio/tests/rt_basic.rs b/tokio/tests/rt_basic.rs index 4f0beab9..38a72692 100644 --- a/tokio/tests/rt_basic.rs +++ b/tokio/tests/rt_basic.rs @@ -44,7 +44,7 @@ fn acquire_mutex_in_drop() { rt.spawn(async move { let _ = rx1.await; - let _ = tx2.send(()).unwrap(); + tx2.send(()).unwrap(); unreachable!(); }); diff --git a/tokio/tests/sync_broadcast.rs b/tokio/tests/sync_broadcast.rs index 257595ca..b6f48ca5 100644 --- a/tokio/tests/sync_broadcast.rs +++ b/tokio/tests/sync_broadcast.rs @@ -1,3 +1,4 @@ +#![allow(clippy::cognitive_complexity)] #![warn(rust_2018_idioms)] #![cfg(feature = "sync")] diff --git a/tokio/tests/task_local_set.rs b/tokio/tests/task_local_set.rs index f5014275..e7cce3aa 100644 --- a/tokio/tests/task_local_set.rs +++ b/tokio/tests/task_local_set.rs @@ -22,7 +22,7 @@ fn acquire_mutex_in_drop() { local.spawn_local(async move { let _ = rx1.await; - let _ = tx2.send(()).unwrap(); + tx2.send(()).unwrap(); unreachable!(); }); |