use crate::offset_from;
use std::cmp::Ordering::{Greater, Less};
use std::slice::{from_raw_parts, from_raw_parts_mut};
use std::{fmt, marker};
macro_rules! binary_group_by {
(struct $name:ident, $elem:ty, $mkslice:ident) => {
impl<'a, T: 'a, P> $name<'a, T, P> {
#[inline]
pub fn is_empty(&self) -> bool {
self.ptr == self.end
}
#[inline]
pub fn remainder_len(&self) -> usize {
unsafe { offset_from(self.end, self.ptr) }
}
}
impl<'a, T: 'a, P> std::iter::Iterator for $name<'a, T, P>
where
P: FnMut(&T, &T) -> bool,
{
type Item = $elem;
#[inline]
fn next(&mut self) -> Option<Self::Item> {
if self.is_empty() {
return None;
}
let first = unsafe { &*self.ptr };
let len = self.remainder_len();
let tail = unsafe { $mkslice(self.ptr.add(1), len - 1) };
let predicate = |x: &T| {
if (self.predicate)(first, x) {
Less
} else {
Greater
}
};
let index = tail.binary_search_by(predicate).unwrap_err();
let left = unsafe { $mkslice(self.ptr, index + 1) };
self.ptr = unsafe { self.ptr.add(index + 1) };
Some(left)
}
fn size_hint(&self) -> (usize, Option<usize>) {
if self.is_empty() {
return (0, Some(0));
}
let len = self.remainder_len();
(1, Some(len))
}
fn last(mut self) -> Option<Self::Item> {
self.next_back()
}
}
impl<'a, T: 'a, P> std::iter::DoubleEndedIterator for $name<'a, T, P>
where
P: FnMut(&T, &T) -> bool,
{
#[inline]
fn next_back(&mut self) -> Option<Self::Item> {
if self.is_empty() {
return None;
}
let last = unsafe { &*self.end.sub(1) };
let len = self.remainder_len();
let head = unsafe { $mkslice(self.ptr, len - 1) };
let predicate = |x: &T| {
if (self.predicate)(last, x) {
Greater
} else {
Less
}
};
let index = head.binary_search_by(predicate).unwrap_err();
let right = unsafe { $mkslice(self.ptr.add(index), len - index) };
self.end = unsafe { self.end.sub(len - index) };
Some(right)
}
}
impl<'a, T: 'a, P> std::iter::FusedIterator for $name<'a, T, P> where
P: FnMut(&T, &T) -> bool
{
}
};
}
pub struct BinaryGroupBy<'a, T, P> {
ptr: *const T,
end: *const T,
predicate: P,
_phantom: marker::PhantomData<&'a T>,
}
impl<'a, T: 'a, P> BinaryGroupBy<'a, T, P> {
pub fn new(slice: &'a [T], predicate: P) -> Self {
BinaryGroupBy {
ptr: slice.as_ptr(),
end: unsafe { slice.as_ptr().add(slice.len()) },
predicate,
_phantom: marker::PhantomData,
}
}
}
impl<'a, T: 'a, P> BinaryGroupBy<'a, T, P> {
pub fn remainder(&self) -> &[T] {
let len = self.remainder_len();
unsafe { from_raw_parts(self.ptr, len) }
}
}
impl<'a, T: 'a + fmt::Debug, P> fmt::Debug for BinaryGroupBy<'a, T, P> {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
f.debug_struct("BinaryGroupBy")
.field("remainder", &self.remainder())
.finish()
}
}
binary_group_by! { struct BinaryGroupBy, &'a [T], from_raw_parts }
pub struct BinaryGroupByMut<'a, T, P> {
ptr: *mut T,
end: *mut T,
predicate: P,
_phantom: marker::PhantomData<&'a mut T>,
}
impl<'a, T: 'a, P> BinaryGroupByMut<'a, T, P>
where
P: FnMut(&T, &T) -> bool,
{
pub fn new(slice: &'a mut [T], predicate: P) -> Self {
let ptr = slice.as_mut_ptr();
let end = unsafe { ptr.add(slice.len()) };
BinaryGroupByMut {
ptr,
end,
predicate,
_phantom: marker::PhantomData,
}
}
}
impl<'a, T: 'a, P> BinaryGroupByMut<'a, T, P> {
pub fn into_remainder(self) -> &'a mut [T] {
let len = self.remainder_len();
unsafe { from_raw_parts_mut(self.ptr, len) }
}
}
impl<'a, T: 'a + fmt::Debug, P> fmt::Debug for BinaryGroupByMut<'a, T, P> {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
let len = self.remainder_len();
let remainder = unsafe { from_raw_parts(self.ptr, len) };
f.debug_struct("BinaryGroupByMut")
.field("remainder", &remainder)
.finish()
}
}
binary_group_by! { struct BinaryGroupByMut, &'a mut [T], from_raw_parts_mut }