(&self, array: &str)
| 234 | #[cfg(test)] |
| 235 | impl ApplyEngine for MockEngine { |
| 236 | fn schema_hlc(&self, array: &str) -> ArrayResult<Option<Hlc>> { |
| 237 | Ok(self.schemas.get(array).copied()) |
| 238 | } |
| 239 | |
| 240 | fn already_seen(&self, array: &str, hlc: Hlc) -> ArrayResult<bool> { |
| 241 | Ok(self.seen.contains(&(array.to_string(), hlc.to_bytes()))) |