use core::ptr::{self};
use core::slice::{self};
use crate::alloc::Allocator;
use crate::error::Error;
use super::{Drain, Vec};
pub(crate) fn splice<'a, I, A>(
drain: &mut Drain<'a, I::Item, A>,
replace_with: &mut I,
) -> Result<(), Error>
where
I: Iterator + 'a,
A: Allocator + 'a,
{
for element in drain.by_ref() {
drop(element);
}
drain.iter = [].iter();
unsafe {
if drain.tail_len == 0 {
let out = drain.vec.as_mut();
for element in replace_with.by_ref() {
out.try_push(element)?;
}
return Ok(());
}
if !drain.fill(replace_with) {
return Ok(());
}
let (lower_bound, _upper_bound) = replace_with.size_hint();
if lower_bound > 0 {
drain.move_tail(lower_bound)?;
if !drain.fill(replace_with) {
return Ok(());
}
}
let mut collected = Vec::new_in(drain.vec.as_ref().allocator());
for element in replace_with.by_ref() {
collected.try_push(element)?;
}
let mut collected = collected.into_iter();
if collected.len() > 0 {
drain.move_tail(collected.len())?;
let filled = drain.fill(&mut collected);
debug_assert!(filled);
debug_assert_eq!(collected.len(), 0);
}
Ok(())
}
}
impl<T, A: Allocator> Drain<'_, T, A> {
unsafe fn fill<I: Iterator<Item = T>>(&mut self, replace_with: &mut I) -> bool {
let vec = unsafe { self.vec.as_mut() };
let range_start = vec.len;
let range_end = self.tail_start;
let range_slice = unsafe {
slice::from_raw_parts_mut(vec.as_mut_ptr().add(range_start), range_end - range_start)
};
for place in range_slice {
if let Some(new_item) = replace_with.next() {
unsafe { ptr::write(place, new_item) };
vec.len += 1;
} else {
return false;
}
}
true
}
unsafe fn move_tail(&mut self, additional: usize) -> Result<(), Error> {
let vec = unsafe { self.vec.as_mut() };
let len = self.tail_start + self.tail_len;
vec.buf.try_reserve(len, additional)?;
let new_tail_start = self.tail_start + additional;
unsafe {
let src = vec.as_ptr().add(self.tail_start);
let dst = vec.as_mut_ptr().add(new_tail_start);
ptr::copy(src, dst, self.tail_len);
}
self.tail_start = new_tail_start;
Ok(())
}
}