(&self, op: &ArrayOp)
| 78 | |
| 79 | impl OpLog for InMemoryOpLog { |
| 80 | fn append(&self, op: &ArrayOp) -> ArrayResult<()> { |
| 81 | let key = (op.header.array.clone(), op.header.hlc.to_bytes()); |
| 82 | self.lock()?.entry(key).or_insert_with(|| op.clone()); |
| 83 | Ok(()) |
| 84 | } |
| 85 | |
| 86 | fn scan_from<'a>(&'a self, from: Hlc) -> ArrayResult<OpIter<'a>> { |
| 87 | let guard = self.lock()?; |