Skip to main content

replay_cursor_decision

Function replay_cursor_decision 

Source
pub fn replay_cursor_decision(
    cursor: i64,
    next: Option<i64>,
) -> ReplayCursorDecision
Expand description

Advance a replay cursor to the next batch offset the reader reported, and stop when there is none or it would not move the cursor forward, so a replay loop always terminates.