(&mut self, data_write: DataWriteCommit<K, V, T, D>)
| 822 | } |
| 823 | |
| 824 | pub(crate) fn put_write_for_commit(&mut self, data_write: DataWriteCommit<K, V, T, D>) { |
| 825 | let prev = self |
| 826 | .data_write_for_commit |
| 827 | .insert(data_write.shard_id(), data_write); |
| 828 | assert!(prev.is_none()); |
| 829 | } |
| 830 | } |
| 831 | |
| 832 | /// A newtype wrapper around [WriteHandle] indicating that it has a real schema |