bug-fix

pragmaxim-com · Jun 11, 2024 · 93cc045 · 93cc045
1 parent 753a385
commit 93cc045
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/.gitignore b/.gitignore
@@ -10,3 +10,4 @@ Cargo.lock
 **/*.rs.bk
 
 .idea
+/.vscode/
diff --git a/src/lib.rs b/src/lib.rs
@@ -130,6 +130,7 @@ where
                     me.items.push(item);
                     *me.current_batch_size += new_count;
                     if me.current_batch_size >= me.min_batch_size {
+                        *me.current_batch_size = 0;
                         return Poll::Ready(Some(std::mem::take(me.items)));
                     }
                 }
Original file line number	Diff line number	Diff line change
Expand Up		@@ -10,3 +10,4 @@ Cargo.lock
		*/.rs.bk

		.idea
		/.vscode/