Current value without incrementing (for snapshot watermarks).
(&self)
| 26 | |
| 27 | /// Current value without incrementing (for snapshot watermarks). |
| 28 | pub fn current(&self) -> Lsn { |
| 29 | Lsn::new(self.current.load(Ordering::Relaxed)) |
| 30 | } |
| 31 | } |
| 32 | |
| 33 | #[cfg(test)] |
no test coverage detected