Skip to content

Commit

Permalink
rename var
Browse files Browse the repository at this point in the history
Signed-off-by: Vaibhav Rabber <[email protected]>
  • Loading branch information
vrongmeal committed Nov 13, 2024
1 parent 44f6aa2 commit 8130f37
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/streams.rs
Original file line number Diff line number Diff line change
Expand Up @@ -195,7 +195,7 @@ impl AppendRecordStream {
// Next linger duration should be none.
Duration::ZERO
} else {
let batch_size = batch.len() as u64;
let batch_len = batch.len() as u64;

yield types::AppendInput {
records: batch,
Expand All @@ -204,7 +204,7 @@ impl AppendRecordStream {
};

if let Some(m) = next_match_seq_num.as_mut() {
*m += batch_size;
*m += batch_len;
}

// Next linger durationis same as the original.
Expand Down

0 comments on commit 8130f37

Please sign in to comment.