use core::iter::FlatMap; /// A specialized version of `core::iter::FlatMap` for mapping over exact-sized /// iterators with a function that returns an array. /// /// `ArrayFlatMap` differs from `FlatMap` in that `ArrayFlatMap` implements /// `ExactSizeIterator`. Since the result of `F` always has `LEN` elements, if /// `I` is an exact-sized iterator of length `inner_len` then we know the /// length of the flat-mapped result is `inner_len * LEN`. (The constructor /// verifies that this multiplication doesn't overflow `usize`.) #[derive(Clone)] pub struct ArrayFlatMap { inner: FlatMap, remaining: usize, } impl ArrayFlatMap where I: ExactSizeIterator, F: FnMut(I::Item) -> [Item; LEN], { /// Constructs an `ArrayFlatMap` wrapping the given iterator, using the /// given function pub fn new(inner: I, f: F) -> Option { let remaining = inner.len().checked_mul(LEN)?; let inner = inner.flat_map(f); Some(Self { inner, remaining }) } } impl Iterator for ArrayFlatMap where I: Iterator, F: FnMut(I::Item) -> [Item; LEN], { type Item = Item; fn next(&mut self) -> Option { let result = self.inner.next(); if result.is_some() { self.remaining -= 1; } result } /// Required for implementing `ExactSizeIterator`. fn size_hint(&self) -> (usize, Option) { (self.remaining, Some(self.remaining)) } } impl ExactSizeIterator for ArrayFlatMap where I: Iterator, F: FnMut(I::Item) -> [Item; LEN], { } #[cfg(test)] mod tests { use super::*; #[test] fn test_array_flat_map() { static TEST_CASES: &[(&[u16], fn(u16) -> [u8; 2], &[u8])] = &[ // Empty input (&[], u16::to_be_bytes, &[]), // Non-empty input. ( &[0x0102, 0x0304, 0x0506], u16::to_be_bytes, &[1, 2, 3, 4, 5, 6], ), // Test with a different mapping function. ( &[0x0102, 0x0304, 0x0506], u16::to_le_bytes, &[2, 1, 4, 3, 6, 5], ), ]; TEST_CASES.iter().copied().for_each(|(input, f, expected)| { let mapped = ArrayFlatMap::new(input.iter().copied(), f).unwrap(); super::super::test::assert_iterator(mapped, expected); }); } // Does ArrayFlatMap::new() handle overflow correctly? #[test] fn test_array_flat_map_len_overflow() { struct DownwardCounter { remaining: usize, } impl Iterator for DownwardCounter { type Item = usize; fn next(&mut self) -> Option { if self.remaining > 0 { let result = self.remaining; self.remaining -= 1; Some(result) } else { None } } fn size_hint(&self) -> (usize, Option) { (self.remaining, Some(self.remaining)) } } impl ExactSizeIterator for DownwardCounter {} const MAX: usize = usize::MAX / core::mem::size_of::(); static TEST_CASES: &[(usize, bool)] = &[(MAX, true), (MAX + 1, false)]; TEST_CASES.iter().copied().for_each(|(input_len, is_some)| { let inner = DownwardCounter { remaining: input_len, }; let mapped = ArrayFlatMap::new(inner, usize::to_be_bytes); assert_eq!(mapped.is_some(), is_some); if let Some(mapped) = mapped { assert_eq!(mapped.len(), input_len * core::mem::size_of::()); } }); } }