Merge #683

683: impl ParallelExtend<()> for () r=cuviper a=cuviper Mirrors rust-lang/rust#50234 Co-authored-by: Josh Stone <[email protected]>
rayon-rs · Aug 22, 2019 · d993d7a · d993d7a
2 parents 2720d8d + c6a294b
commit d993d7a
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/src/iter/extend.rs b/src/iter/extend.rs
@@ -1,3 +1,4 @@
+use super::noop::NoopConsumer;
 use super::{IntoParallelIterator, ParallelExtend, ParallelIterator};
 
 use std::borrow::Cow;
@@ -368,3 +369,13 @@ where
         self.par_extend(par_iter.into_par_iter().cloned())
     }
 }
+
+/// Collapses all unit items from a parallel iterator into one.
+impl ParallelExtend<()> for () {
+    fn par_extend<I>(&mut self, par_iter: I)
+    where
+        I: IntoParallelIterator<Item = ()>,
+    {
+        par_iter.into_par_iter().drive_unindexed(NoopConsumer)
+    }
+}