database-stream-processor
database-stream-processor copied to clipboard
Can radix_tree_update be slightly simplified?
let agg = if input.key_valid() && input.key() == input_delta.key() {
aggregator.aggregate(&mut CursorGroup::new(&mut input, ()))
} else {
None
};
The spec of the aggregate function seems it to require None anyway for an empty input set.