use set immediate

Author: ptiurin

test/integration/v2/stream.test.ts

@@ -13,7 +13,7 @@ const connectionParams = {
   engineName: process.env.FIREBOLT_ENGINE_NAME as string
 };
 
-jest.setTimeout(500000);
+jest.setTimeout(350000);
 
 describe("streams", () => {
   it("check sum from stream result", async () => {
@@ -404,11 +404,11 @@ describe("streams", () => {
       write(chunk, encoding, callback) {
         processedChunks++;
 
-        // Simulate occasional slow processing with minimal delays
-        if (processedChunks % 2000 === 0) {
-          setTimeout(() => {
+        // Simulate occasional slow processing with event loop yielding
+        if (processedChunks % 1000 === 0) {
+          setImmediate(() => {
             callback();
-          }, 1); // 1ms delay
+          });
         } else {
           callback();
         }