1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105

use crate::{iter::RawCursor, Storage};

/// This struct is created by [`GenericVec::splice`](crate::GenericVec::splice).
/// See its documentation for more.
pub struct Splice<'a, T, S, I>
where
    S: ?Sized + Storage<T>,
    I: Iterator<Item = T>,
{
    raw: RawCursor<'a, T, S>,
    replace_with: I,
}

impl<'a, T, S: ?Sized + Storage<T>, I: Iterator<Item = T>> Splice<'a, T, S, I> {
    pub(crate) fn new(raw: RawCursor<'a, T, S>, replace_with: I) -> Self { Self { raw, replace_with } }
}

impl<T, S: ?Sized + Storage<T>, I: Iterator<Item = T>> Drop for Splice<'_, T, S, I> {
    fn drop(&mut self) {
        unsafe {
            self.raw.drop_n_front(self.raw.len());
        }

        let Self { raw, replace_with } = self;

        if raw.at_back_of_vec() {
            self.raw.finish();
            unsafe { self.raw.vec_mut().extend(replace_with) }
            return
        }

        while !raw.is_write_empty() {
            match replace_with.next() {
                Some(value) => unsafe { raw.write_front(value) },
                None => return,
            }
        }

        #[cfg(not(feature = "alloc"))]
        {
            const CAPACITY: usize = 16;

            let mut buffer = crate::uninit_array::<_, CAPACITY>();
            let mut buffer = crate::SliceVec::new(&mut buffer);

            replace_with.for_each(|item| unsafe {
                buffer.push_unchecked(item);

                if buffer.is_full() {
                    unsafe {
                        raw.reserve(buffer.len());
                        raw.write_slice_front(&buffer);
                        buffer.set_len_unchecked(0);
                    }
                }
            });

            unsafe {
                raw.reserve(buffer.len());
                raw.write_slice_front(&buffer);
                core::mem::forget(buffer);
            }
        }

        #[cfg(feature = "alloc")]
        {
            let mut temp: std::vec::Vec<T> = replace_with.collect();

            unsafe {
                raw.reserve(temp.len());
                raw.write_slice_front(&temp);
                temp.set_len(0);
            }
        }
    }
}

impl<T, S: ?Sized + Storage<T>, I: Iterator<Item = T>> ExactSizeIterator for Splice<'_, T, S, I> {}

impl<'a, T, S: ?Sized + Storage<T>, I: Iterator<Item = T>> Iterator for Splice<'a, T, S, I> {
    type Item = I::Item;

    fn next(&mut self) -> Option<Self::Item> {
        if self.raw.is_empty() {
            None
        } else {
            Some(unsafe { self.raw.take_front() })
        }
    }

    fn size_hint(&self) -> (usize, Option<usize>) {
        let size = self.raw.len();
        (size, Some(size))
    }
}

impl<'a, T, S: ?Sized + Storage<T>, I: Iterator<Item = T>> DoubleEndedIterator for Splice<'a, T, S, I> {
    fn next_back(&mut self) -> Option<Self::Item> {
        if self.raw.is_empty() {
            None
        } else {
            Some(unsafe { self.raw.take_back() })
        }
    }
}