(&self)
| 812 | } |
| 813 | |
| 814 | fn expected_offset(&self) -> &u64 { |
| 815 | match self { |
| 816 | Self::Initial { next_offset } => next_offset, |
| 817 | Self::LastSeen { tx_range, .. } => &tx_range.end, |
| 818 | } |
| 819 | } |
| 820 | |
| 821 | // If initial offset falls within a commit, adjust it to the commit boundary. |
| 822 | // |
no outgoing calls
no test coverage detected