mod cursor; use arrayvec::ArrayVec; pub use cursor::Cursor; pub use cursor::FilterCursor; use std::{cmp::Ordering, fmt, iter::FromIterator, sync::Arc}; #[cfg(test)] const TREE_BASE: usize = 2; #[cfg(not(test))] const TREE_BASE: usize = 6; pub trait Item: Clone + fmt::Debug { type Summary: Summary; fn summary(&self) -> Self::Summary; } pub trait KeyedItem: Item { type Key: for<'a> Dimension<'a, Self::Summary> + Ord; fn key(&self) -> Self::Key; } pub trait Summary: Default + Clone + fmt::Debug { type Context; fn add_summary(&mut self, summary: &Self, ctx: &Self::Context); } pub trait Dimension<'a, S: Summary>: Clone + fmt::Debug + Default { fn add_summary(&mut self, _summary: &'a S); } impl<'a, T: Summary> Dimension<'a, T> for () { fn add_summary(&mut self, _: &'a T) {} } pub trait SeekDimension<'a, T: Summary>: Dimension<'a, T> { fn cmp(&self, other: &Self, ctx: &T::Context) -> Ordering; } impl<'a, S: Summary, T: Dimension<'a, S> + Ord> SeekDimension<'a, S> for T { fn cmp(&self, other: &Self, _ctx: &S::Context) -> Ordering { Ord::cmp(self, other) } } #[derive(Copy, Clone, Eq, PartialEq)] pub enum SeekBias { Left, Right, } #[derive(Debug, Clone)] pub struct SumTree(Arc>); impl SumTree { pub fn new() -> Self { SumTree(Arc::new(Node::Leaf { summary: T::Summary::default(), items: ArrayVec::new(), item_summaries: ArrayVec::new(), })) } pub fn from_item(item: T, ctx: &::Context) -> Self { let mut tree = Self::new(); tree.push(item, ctx); tree } #[allow(unused)] pub fn items(&self) -> Vec { let mut cursor = self.cursor::<(), ()>(); cursor.cloned().collect() } pub fn cursor<'a, S, U>(&'a self) -> Cursor where S: Dimension<'a, T::Summary>, U: Dimension<'a, T::Summary>, { Cursor::new(self) } pub fn filter<'a, F, U>(&'a self, filter_node: F) -> FilterCursor where F: Fn(&T::Summary) -> bool, U: Dimension<'a, T::Summary>, { FilterCursor::new(self, filter_node) } #[allow(dead_code)] pub fn first(&self) -> Option<&T> { self.leftmost_leaf().0.items().first() } pub fn last(&self) -> Option<&T> { self.rightmost_leaf().0.items().last() } pub fn update_last(&mut self, f: impl FnOnce(&mut T), ctx: &::Context) { self.update_last_recursive(f, ctx); } fn update_last_recursive( &mut self, f: impl FnOnce(&mut T), ctx: &::Context, ) -> Option { match Arc::make_mut(&mut self.0) { Node::Internal { summary, child_summaries, child_trees, .. } => { let last_summary = child_summaries.last_mut().unwrap(); let last_child = child_trees.last_mut().unwrap(); *last_summary = last_child.update_last_recursive(f, ctx).unwrap(); *summary = sum(child_summaries.iter(), ctx); Some(summary.clone()) } Node::Leaf { summary, items, item_summaries, } => { if let Some((item, item_summary)) = items.last_mut().zip(item_summaries.last_mut()) { (f)(item); *item_summary = item.summary(); *summary = sum(item_summaries.iter(), ctx); Some(summary.clone()) } else { None } } } } pub fn extent<'a, D: Dimension<'a, T::Summary>>(&'a self) -> D { let mut extent = D::default(); match self.0.as_ref() { Node::Internal { summary, .. } | Node::Leaf { summary, .. } => { extent.add_summary(summary); } } extent } pub fn summary(&self) -> T::Summary { match self.0.as_ref() { Node::Internal { summary, .. } => summary.clone(), Node::Leaf { summary, .. } => summary.clone(), } } pub fn is_empty(&self) -> bool { match self.0.as_ref() { Node::Internal { .. } => false, Node::Leaf { items, .. } => items.is_empty(), } } pub fn extend(&mut self, iter: I, ctx: &::Context) where I: IntoIterator, { let mut leaf: Option> = None; for item in iter { if leaf.is_some() && leaf.as_ref().unwrap().items().len() == 2 * TREE_BASE { self.push_tree(SumTree(Arc::new(leaf.take().unwrap())), ctx); } if leaf.is_none() { leaf = Some(Node::Leaf:: { summary: T::Summary::default(), items: ArrayVec::new(), item_summaries: ArrayVec::new(), }); } if let Some(Node::Leaf { summary, items, item_summaries, }) = leaf.as_mut() { let item_summary = item.summary(); summary.add_summary(&item_summary, ctx); items.push(item); item_summaries.push(item_summary); } else { unreachable!() } } if leaf.is_some() { self.push_tree(SumTree(Arc::new(leaf.take().unwrap())), ctx); } } pub fn push(&mut self, item: T, ctx: &::Context) { let summary = item.summary(); self.push_tree( SumTree::from_child_trees( vec![SumTree(Arc::new(Node::Leaf { summary: summary.clone(), items: ArrayVec::from_iter(Some(item)), item_summaries: ArrayVec::from_iter(Some(summary)), }))], ctx, ), ctx, ) } pub fn push_tree(&mut self, other: Self, ctx: &::Context) { let other_node = other.0.clone(); if !other_node.is_leaf() || other_node.items().len() > 0 { if self.0.height() < other_node.height() { for tree in other_node.child_trees() { self.push_tree(tree.clone(), ctx); } } else if let Some(split_tree) = self.push_tree_recursive(other, ctx) { *self = Self::from_child_trees(vec![self.clone(), split_tree], ctx); } } } fn push_tree_recursive( &mut self, other: SumTree, ctx: &::Context, ) -> Option> { match Arc::make_mut(&mut self.0) { Node::Internal { height, summary, child_summaries, child_trees, .. } => { let other_node = other.0.clone(); summary.add_summary(other_node.summary(), ctx); let height_delta = *height - other_node.height(); let mut summaries_to_append = ArrayVec::<[T::Summary; 2 * TREE_BASE]>::new(); let mut trees_to_append = ArrayVec::<[SumTree; 2 * TREE_BASE]>::new(); if height_delta == 0 { summaries_to_append.extend(other_node.child_summaries().iter().cloned()); trees_to_append.extend(other_node.child_trees().iter().cloned()); } else if height_delta == 1 && !other_node.is_underflowing() { summaries_to_append.push(other_node.summary().clone()); trees_to_append.push(other) } else { let tree_to_append = child_trees .last_mut() .unwrap() .push_tree_recursive(other, ctx); *child_summaries.last_mut().unwrap() = child_trees.last().unwrap().0.summary().clone(); if let Some(split_tree) = tree_to_append { summaries_to_append.push(split_tree.0.summary().clone()); trees_to_append.push(split_tree); } } let child_count = child_trees.len() + trees_to_append.len(); if child_count > 2 * TREE_BASE { let left_summaries: ArrayVec<_>; let right_summaries: ArrayVec<_>; let left_trees; let right_trees; let midpoint = (child_count + child_count % 2) / 2; { let mut all_summaries = child_summaries .iter() .chain(summaries_to_append.iter()) .cloned(); left_summaries = all_summaries.by_ref().take(midpoint).collect(); right_summaries = all_summaries.collect(); let mut all_trees = child_trees.iter().chain(trees_to_append.iter()).cloned(); left_trees = all_trees.by_ref().take(midpoint).collect(); right_trees = all_trees.collect(); } *summary = sum(left_summaries.iter(), ctx); *child_summaries = left_summaries; *child_trees = left_trees; Some(SumTree(Arc::new(Node::Internal { height: *height, summary: sum(right_summaries.iter(), ctx), child_summaries: right_summaries, child_trees: right_trees, }))) } else { child_summaries.extend(summaries_to_append); child_trees.extend(trees_to_append); None } } Node::Leaf { summary, items, item_summaries, } => { let other_node = other.0; let child_count = items.len() + other_node.items().len(); if child_count > 2 * TREE_BASE { let left_items; let right_items; let left_summaries; let right_summaries: ArrayVec<[T::Summary; 2 * TREE_BASE]>; let midpoint = (child_count + child_count % 2) / 2; { let mut all_items = items.iter().chain(other_node.items().iter()).cloned(); left_items = all_items.by_ref().take(midpoint).collect(); right_items = all_items.collect(); let mut all_summaries = item_summaries .iter() .chain(other_node.child_summaries()) .cloned(); left_summaries = all_summaries.by_ref().take(midpoint).collect(); right_summaries = all_summaries.collect(); } *items = left_items; *item_summaries = left_summaries; *summary = sum(item_summaries.iter(), ctx); Some(SumTree(Arc::new(Node::Leaf { items: right_items, summary: sum(right_summaries.iter(), ctx), item_summaries: right_summaries, }))) } else { summary.add_summary(other_node.summary(), ctx); items.extend(other_node.items().iter().cloned()); item_summaries.extend(other_node.child_summaries().iter().cloned()); None } } } } fn from_child_trees( child_trees: Vec>, ctx: &::Context, ) -> Self { let height = child_trees[0].0.height() + 1; let mut child_summaries = ArrayVec::new(); for child in &child_trees { child_summaries.push(child.0.summary().clone()); } let summary = sum(child_summaries.iter(), ctx); SumTree(Arc::new(Node::Internal { height, summary, child_summaries, child_trees: ArrayVec::from_iter(child_trees), })) } fn leftmost_leaf(&self) -> &Self { match *self.0 { Node::Leaf { .. } => self, Node::Internal { ref child_trees, .. } => child_trees.first().unwrap().leftmost_leaf(), } } fn rightmost_leaf(&self) -> &Self { match *self.0 { Node::Leaf { .. } => self, Node::Internal { ref child_trees, .. } => child_trees.last().unwrap().rightmost_leaf(), } } } impl SumTree { #[allow(unused)] pub fn insert(&mut self, item: T, ctx: &::Context) { *self = { let mut cursor = self.cursor::(); let mut new_tree = cursor.slice(&item.key(), SeekBias::Left, ctx); new_tree.push(item, ctx); new_tree.push_tree(cursor.suffix(ctx), ctx); new_tree }; } pub fn edit( &mut self, mut edits: Vec>, ctx: &::Context, ) -> Vec { if edits.is_empty() { return Vec::new(); } let mut removed = Vec::new(); edits.sort_unstable_by_key(|item| item.key()); *self = { let mut cursor = self.cursor::(); let mut new_tree = SumTree::new(); let mut buffered_items = Vec::new(); cursor.seek(&T::Key::default(), SeekBias::Left, ctx); for edit in edits { let new_key = edit.key(); let mut old_item = cursor.item(); if old_item .as_ref() .map_or(false, |old_item| old_item.key() < new_key) { new_tree.extend(buffered_items.drain(..), ctx); let slice = cursor.slice(&new_key, SeekBias::Left, ctx); new_tree.push_tree(slice, ctx); old_item = cursor.item(); } if let Some(old_item) = old_item { if old_item.key() == new_key { removed.push(old_item.clone()); cursor.next(); } } match edit { Edit::Insert(item) => { buffered_items.push(item); } Edit::Remove(_) => {} } } new_tree.extend(buffered_items, ctx); new_tree.push_tree(cursor.suffix(ctx), ctx); new_tree }; removed } pub fn get(&self, key: &T::Key, ctx: &::Context) -> Option<&T> { let mut cursor = self.cursor::(); if cursor.seek(key, SeekBias::Left, ctx) { cursor.item() } else { None } } } impl Default for SumTree { fn default() -> Self { Self::new() } } #[derive(Clone, Debug)] pub enum Node { Internal { height: u8, summary: T::Summary, child_summaries: ArrayVec<[T::Summary; 2 * TREE_BASE]>, child_trees: ArrayVec<[SumTree; 2 * TREE_BASE]>, }, Leaf { summary: T::Summary, items: ArrayVec<[T; 2 * TREE_BASE]>, item_summaries: ArrayVec<[T::Summary; 2 * TREE_BASE]>, }, } impl Node { fn is_leaf(&self) -> bool { match self { Node::Leaf { .. } => true, _ => false, } } fn height(&self) -> u8 { match self { Node::Internal { height, .. } => *height, Node::Leaf { .. } => 0, } } fn summary(&self) -> &T::Summary { match self { Node::Internal { summary, .. } => summary, Node::Leaf { summary, .. } => summary, } } fn child_summaries(&self) -> &[T::Summary] { match self { Node::Internal { child_summaries, .. } => child_summaries.as_slice(), Node::Leaf { item_summaries, .. } => item_summaries.as_slice(), } } fn child_trees(&self) -> &ArrayVec<[SumTree; 2 * TREE_BASE]> { match self { Node::Internal { child_trees, .. } => child_trees, Node::Leaf { .. } => panic!("Leaf nodes have no child trees"), } } fn items(&self) -> &ArrayVec<[T; 2 * TREE_BASE]> { match self { Node::Leaf { items, .. } => items, Node::Internal { .. } => panic!("Internal nodes have no items"), } } fn is_underflowing(&self) -> bool { match self { Node::Internal { child_trees, .. } => child_trees.len() < TREE_BASE, Node::Leaf { items, .. } => items.len() < TREE_BASE, } } } #[derive(Debug)] pub enum Edit { Insert(T), Remove(T::Key), } impl Edit { fn key(&self) -> T::Key { match self { Edit::Insert(item) => item.key(), Edit::Remove(key) => key.clone(), } } } fn sum<'a, T, I>(iter: I, ctx: &T::Context) -> T where T: 'a + Summary, I: Iterator, { let mut sum = T::default(); for value in iter { sum.add_summary(value, ctx); } sum } #[cfg(test)] mod tests { use super::*; use std::cmp; use std::ops::Add; #[test] fn test_extend_and_push_tree() { let mut tree1 = SumTree::new(); tree1.extend(0..20, &()); let mut tree2 = SumTree::new(); tree2.extend(50..100, &()); tree1.push_tree(tree2, &()); assert_eq!(tree1.items(), (0..20).chain(50..100).collect::>()); } #[test] fn test_random() { for seed in 0..100 { use rand::{distributions, prelude::*}; dbg!(seed); let rng = &mut StdRng::seed_from_u64(seed); let mut tree = SumTree::::new(); let count = rng.gen_range(0..10); tree.extend(rng.sample_iter(distributions::Standard).take(count), &()); for _ in 0..5 { let splice_end = rng.gen_range(0..tree.extent::().0 + 1); let splice_start = rng.gen_range(0..splice_end + 1); let count = rng.gen_range(0..3); let tree_end = tree.extent::(); let new_items = rng .sample_iter(distributions::Standard) .take(count) .collect::>(); let mut reference_items = tree.items(); reference_items.splice(splice_start..splice_end, new_items.clone()); tree = { let mut cursor = tree.cursor::(); let mut new_tree = cursor.slice(&Count(splice_start), SeekBias::Right, &()); new_tree.extend(new_items, &()); cursor.seek(&Count(splice_end), SeekBias::Right, &()); new_tree.push_tree(cursor.slice(&tree_end, SeekBias::Right, &()), &()); new_tree }; assert_eq!(tree.items(), reference_items); let mut filter_cursor = tree.filter::<_, Count>(|summary| summary.contains_even); let mut reference_filter = tree .items() .into_iter() .enumerate() .filter(|(_, item)| (item & 1) == 0); while let Some(actual_item) = filter_cursor.item() { let (reference_index, reference_item) = reference_filter.next().unwrap(); assert_eq!(actual_item, &reference_item); assert_eq!(filter_cursor.start().0, reference_index); filter_cursor.next(); } assert!(reference_filter.next().is_none()); let mut pos = rng.gen_range(0..tree.extent::().0 + 1); let mut before_start = false; let mut cursor = tree.cursor::(); cursor.seek(&Count(pos), SeekBias::Right, &()); for i in 0..10 { assert_eq!(cursor.start().0, pos); if pos > 0 { assert_eq!(cursor.prev_item().unwrap(), &reference_items[pos - 1]); } else { assert_eq!(cursor.prev_item(), None); } if pos < reference_items.len() && !before_start { assert_eq!(cursor.item().unwrap(), &reference_items[pos]); } else { assert_eq!(cursor.item(), None); } if i < 5 { cursor.next(); if pos < reference_items.len() { pos += 1; before_start = false; } } else { cursor.prev(); if pos == 0 { before_start = true; } pos = pos.saturating_sub(1); } } } for _ in 0..10 { let end = rng.gen_range(0..tree.extent::().0 + 1); let start = rng.gen_range(0..end + 1); let start_bias = if rng.gen() { SeekBias::Left } else { SeekBias::Right }; let end_bias = if rng.gen() { SeekBias::Left } else { SeekBias::Right }; let mut cursor = tree.cursor::(); cursor.seek(&Count(start), start_bias, &()); let slice = cursor.slice(&Count(end), end_bias, &()); cursor.seek(&Count(start), start_bias, &()); let summary = cursor.summary::(&Count(end), end_bias, &()); assert_eq!(summary, slice.summary().sum); } } } #[test] fn test_cursor() { // Empty tree let tree = SumTree::::new(); let mut cursor = tree.cursor::(); assert_eq!( cursor.slice(&Count(0), SeekBias::Right, &()).items(), Vec::::new() ); assert_eq!(cursor.item(), None); assert_eq!(cursor.prev_item(), None); assert_eq!(cursor.start(), &Sum(0)); // Single-element tree let mut tree = SumTree::::new(); tree.extend(vec![1], &()); let mut cursor = tree.cursor::(); assert_eq!( cursor.slice(&Count(0), SeekBias::Right, &()).items(), Vec::::new() ); assert_eq!(cursor.item(), Some(&1)); assert_eq!(cursor.prev_item(), None); assert_eq!(cursor.start(), &Sum(0)); cursor.next(); assert_eq!(cursor.item(), None); assert_eq!(cursor.prev_item(), Some(&1)); assert_eq!(cursor.start(), &Sum(1)); cursor.prev(); assert_eq!(cursor.item(), Some(&1)); assert_eq!(cursor.prev_item(), None); assert_eq!(cursor.start(), &Sum(0)); let mut cursor = tree.cursor::(); assert_eq!(cursor.slice(&Count(1), SeekBias::Right, &()).items(), [1]); assert_eq!(cursor.item(), None); assert_eq!(cursor.prev_item(), Some(&1)); assert_eq!(cursor.start(), &Sum(1)); cursor.seek(&Count(0), SeekBias::Right, &()); assert_eq!( cursor .slice(&tree.extent::(), SeekBias::Right, &()) .items(), [1] ); assert_eq!(cursor.item(), None); assert_eq!(cursor.prev_item(), Some(&1)); assert_eq!(cursor.start(), &Sum(1)); // Multiple-element tree let mut tree = SumTree::new(); tree.extend(vec![1, 2, 3, 4, 5, 6], &()); let mut cursor = tree.cursor::(); assert_eq!( cursor.slice(&Count(2), SeekBias::Right, &()).items(), [1, 2] ); assert_eq!(cursor.item(), Some(&3)); assert_eq!(cursor.prev_item(), Some(&2)); assert_eq!(cursor.start(), &Sum(3)); cursor.next(); assert_eq!(cursor.item(), Some(&4)); assert_eq!(cursor.prev_item(), Some(&3)); assert_eq!(cursor.start(), &Sum(6)); cursor.next(); assert_eq!(cursor.item(), Some(&5)); assert_eq!(cursor.prev_item(), Some(&4)); assert_eq!(cursor.start(), &Sum(10)); cursor.next(); assert_eq!(cursor.item(), Some(&6)); assert_eq!(cursor.prev_item(), Some(&5)); assert_eq!(cursor.start(), &Sum(15)); cursor.next(); cursor.next(); assert_eq!(cursor.item(), None); assert_eq!(cursor.prev_item(), Some(&6)); assert_eq!(cursor.start(), &Sum(21)); cursor.prev(); assert_eq!(cursor.item(), Some(&6)); assert_eq!(cursor.prev_item(), Some(&5)); assert_eq!(cursor.start(), &Sum(15)); cursor.prev(); assert_eq!(cursor.item(), Some(&5)); assert_eq!(cursor.prev_item(), Some(&4)); assert_eq!(cursor.start(), &Sum(10)); cursor.prev(); assert_eq!(cursor.item(), Some(&4)); assert_eq!(cursor.prev_item(), Some(&3)); assert_eq!(cursor.start(), &Sum(6)); cursor.prev(); assert_eq!(cursor.item(), Some(&3)); assert_eq!(cursor.prev_item(), Some(&2)); assert_eq!(cursor.start(), &Sum(3)); cursor.prev(); assert_eq!(cursor.item(), Some(&2)); assert_eq!(cursor.prev_item(), Some(&1)); assert_eq!(cursor.start(), &Sum(1)); cursor.prev(); assert_eq!(cursor.item(), Some(&1)); assert_eq!(cursor.prev_item(), None); assert_eq!(cursor.start(), &Sum(0)); cursor.prev(); assert_eq!(cursor.item(), None); assert_eq!(cursor.prev_item(), None); assert_eq!(cursor.start(), &Sum(0)); cursor.next(); assert_eq!(cursor.item(), Some(&1)); assert_eq!(cursor.prev_item(), None); assert_eq!(cursor.start(), &Sum(0)); let mut cursor = tree.cursor::(); assert_eq!( cursor .slice(&tree.extent::(), SeekBias::Right, &()) .items(), tree.items() ); assert_eq!(cursor.item(), None); assert_eq!(cursor.prev_item(), Some(&6)); assert_eq!(cursor.start(), &Sum(21)); cursor.seek(&Count(3), SeekBias::Right, &()); assert_eq!( cursor .slice(&tree.extent::(), SeekBias::Right, &()) .items(), [4, 5, 6] ); assert_eq!(cursor.item(), None); assert_eq!(cursor.prev_item(), Some(&6)); assert_eq!(cursor.start(), &Sum(21)); // Seeking can bias left or right cursor.seek(&Count(1), SeekBias::Left, &()); assert_eq!(cursor.item(), Some(&1)); cursor.seek(&Count(1), SeekBias::Right, &()); assert_eq!(cursor.item(), Some(&2)); // Slicing without resetting starts from where the cursor is parked at. cursor.seek(&Count(1), SeekBias::Right, &()); assert_eq!( cursor.slice(&Count(3), SeekBias::Right, &()).items(), vec![2, 3] ); assert_eq!( cursor.slice(&Count(6), SeekBias::Left, &()).items(), vec![4, 5] ); assert_eq!( cursor.slice(&Count(6), SeekBias::Right, &()).items(), vec![6] ); } #[test] fn test_edit() { let mut tree = SumTree::::new(); let removed = tree.edit(vec![Edit::Insert(1), Edit::Insert(2), Edit::Insert(0)], &()); assert_eq!(tree.items(), vec![0, 1, 2]); assert_eq!(removed, Vec::::new()); assert_eq!(tree.get(&0, &()), Some(&0)); assert_eq!(tree.get(&1, &()), Some(&1)); assert_eq!(tree.get(&2, &()), Some(&2)); assert_eq!(tree.get(&4, &()), None); let removed = tree.edit(vec![Edit::Insert(2), Edit::Insert(4), Edit::Remove(0)], &()); assert_eq!(tree.items(), vec![1, 2, 4]); assert_eq!(removed, vec![0, 2]); assert_eq!(tree.get(&0, &()), None); assert_eq!(tree.get(&1, &()), Some(&1)); assert_eq!(tree.get(&2, &()), Some(&2)); assert_eq!(tree.get(&4, &()), Some(&4)); } #[derive(Clone, Default, Debug)] pub struct IntegersSummary { count: Count, sum: Sum, contains_even: bool, max: u8, } #[derive(Ord, PartialOrd, Default, Eq, PartialEq, Clone, Debug)] struct Count(usize); #[derive(Ord, PartialOrd, Default, Eq, PartialEq, Clone, Debug)] struct Sum(usize); impl Item for u8 { type Summary = IntegersSummary; fn summary(&self) -> Self::Summary { IntegersSummary { count: Count(1), sum: Sum(*self as usize), contains_even: (*self & 1) == 0, max: *self, } } } impl KeyedItem for u8 { type Key = u8; fn key(&self) -> Self::Key { *self } } impl Summary for IntegersSummary { type Context = (); fn add_summary(&mut self, other: &Self, _: &()) { self.count.0 += &other.count.0; self.sum.0 += &other.sum.0; self.contains_even |= other.contains_even; self.max = cmp::max(self.max, other.max); } } impl<'a> Dimension<'a, IntegersSummary> for u8 { fn add_summary(&mut self, summary: &IntegersSummary) { *self = summary.max; } } impl<'a> Dimension<'a, IntegersSummary> for Count { fn add_summary(&mut self, summary: &IntegersSummary) { self.0 += summary.count.0; } } impl<'a> Dimension<'a, IntegersSummary> for Sum { fn add_summary(&mut self, summary: &IntegersSummary) { self.0 += summary.sum.0; } } impl<'a> Add<&'a Self> for Sum { type Output = Self; fn add(mut self, other: &Self) -> Self { self.0 += other.0; self } } }