better_collect 0.5.0

use std::{fmt::Debug, iter, marker::PhantomData, ops::AddAssign};

use crate::aggregate::{AggregateOp, assert_op};

/// An [`AggregateOp`] that calculates the sum of items it operated on.
///
/// # Examples
///
/// ```
/// use std::collections::HashMap;
/// use better_collect::{
///     prelude::*,
///     aggregate::{self, GroupMap},
/// };
///
/// let mut collector = HashMap::<_, i32>::new()
///     .into_aggregate(aggregate::Sum::new());
///
/// assert!(collector.collect((1, 1)).is_continue());
/// assert!(collector.collect((1, 4)).is_continue());
/// assert!(collector.collect((2, 1)).is_continue());
/// assert!(collector.collect((1, 2)).is_continue());
/// assert!(collector.collect((2, 3)).is_continue());
///
/// let counts = collector.finish();
///
/// assert_eq!(counts[&1], 7);
/// assert_eq!(counts[&2], 4);
/// ```
pub struct Sum<K, V, T = V> {
    _marker: PhantomData<fn(&K, &mut V, T) -> V>,
}

impl<K, V, T> Sum<K, V, T>
where
    V: iter::Sum<T> + AddAssign<T>,
{
    /// Creates a new instance of this aggregate op.
    #[inline]
    pub const fn new() -> Self {
        assert_op(Self {
            _marker: PhantomData,
        })
    }
}

impl<K, V, T> AggregateOp for Sum<K, V, T>
where
    V: iter::Sum<T> + AddAssign<T>,
{
    type Key = K;

    type Value = V;

    type Item = T;

    #[inline]
    fn new_value(&mut self, _key: &Self::Key, item: Self::Item) -> Self::Value {
        let mut value = iter::empty().sum();
        value += item;
        value
    }

    #[inline]
    fn modify(&mut self, value: &mut Self::Value, item: Self::Item) {
        *value += item;
    }
}

impl<K, V, T> Default for Sum<K, V, T>
where
    V: iter::Sum<T> + AddAssign<T>,
{
    #[inline]
    fn default() -> Self {
        Self::new()
    }
}

impl<K, V, T> Clone for Sum<K, V, T> {
    fn clone(&self) -> Self {
        Self {
            _marker: PhantomData,
        }
    }
}

impl<K, V, T> Debug for Sum<K, V, T> {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        f.debug_struct("Sum").finish()
    }
}