Skip to content

Commit 95cc2f3

Browse files
committed
adjust delay
1 parent f4c68c5 commit 95cc2f3

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

test/integration/v2/stream.test.ts

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -405,13 +405,13 @@ describe("streams", () => {
405405
processedChunks++;
406406

407407
// Simulate occasional slow processing with minimal delays
408-
// if (processedChunks % 1000 === 0) {
409-
// setTimeout(() => {
410-
// callback();
411-
// }, 1); // 1ms delay
412-
// } else {
413-
// callback();
414-
// }
408+
if (processedChunks % 5000 === 0) {
409+
setTimeout(() => {
410+
callback();
411+
}, 1); // 1ms delay
412+
} else {
413+
callback();
414+
}
415415
callback();
416416
}
417417
});

0 commit comments

Comments
 (0)