Skip to content

Commit f4c68c5

Browse files
committed
no delay
1 parent 6f59352 commit f4c68c5

File tree

1 file changed

+9
-8
lines changed

1 file changed

+9
-8
lines changed

test/integration/v2/stream.test.ts

Lines changed: 9 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ const connectionParams = {
1313
engineName: process.env.FIREBOLT_ENGINE_NAME as string
1414
};
1515

16-
jest.setTimeout(350000);
16+
jest.setTimeout(150000);
1717

1818
describe("streams", () => {
1919
it("check sum from stream result", async () => {
@@ -405,13 +405,14 @@ 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 % 1000 === 0) {
409+
// setTimeout(() => {
410+
// callback();
411+
// }, 1); // 1ms delay
412+
// } else {
413+
// callback();
414+
// }
415+
callback();
415416
}
416417
});
417418

0 commit comments

Comments
 (0)