(&'a self, from: Hlc)
| 84 | } |
| 85 | |
| 86 | fn scan_from<'a>(&'a self, from: Hlc) -> ArrayResult<OpIter<'a>> { |
| 87 | let guard = self.lock()?; |
| 88 | let results: Vec<ArrayOp> = guard |
| 89 | .iter() |
| 90 | .filter(|((_, hlc_bytes), _)| { |
| 91 | let hlc = Hlc::from_bytes(hlc_bytes); |
| 92 | hlc >= from |
| 93 | }) |
| 94 | .map(|(_, op)| op.clone()) |
| 95 | .collect(); |
| 96 | Ok(Box::new(results.into_iter().map(Ok))) |
| 97 | } |
| 98 | |
| 99 | fn scan_range<'a>(&'a self, array: &str, from: Hlc, to: Hlc) -> ArrayResult<OpIter<'a>> { |
| 100 | let guard = self.lock()?; |