(&mut self, inserts: &mut RowEventMap<'r, Row>, insert: &'r WithBsatn<Row>)
| 246 | } |
| 247 | |
| 248 | fn handle_insert<'r>(&mut self, inserts: &mut RowEventMap<'r, Row>, insert: &'r WithBsatn<Row>) { |
| 249 | let entry = self.entries.entry(insert.bsatn.clone()); |
| 250 | let entry = entry.or_insert_with(|| { |
| 251 | // First time inserting this row, so let's add an insertion event. |
| 252 | inserts.insert(&insert.bsatn, &insert.row); |
| 253 | RowEntry { |
| 254 | row: insert.row.clone(), |
| 255 | ref_count: 0, |
| 256 | } |
| 257 | }); |
| 258 | entry.ref_count += 1; |
| 259 | } |
| 260 | |
| 261 | /// Apply all the deletes and inserts recorded in `diff`. |
| 262 | /// Return a [`TableAppliedDiff`] which encodes the actual changes to rows present or deleted |
no test coverage detected