Reports the current read frontier.
(&self)
| 2646 | |
| 2647 | /// Reports the current read frontier. |
| 2648 | fn read_frontier(&self) -> Antichain<Timestamp> { |
| 2649 | self.shared |
| 2650 | .lock_read_capabilities(|c| c.frontier().to_owned()) |
| 2651 | } |
| 2652 | |
| 2653 | /// Reports the current write frontier. |
| 2654 | fn write_frontier(&self) -> Antichain<Timestamp> { |
no test coverage detected