fix: test add delay

dao-xyz · Dec 5, 2023 · 36260ea · 36260ea
1 parent 110517f
commit 36260ea
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/packages/transport/stream/src/__tests__/stream.test.ts b/packages/transport/stream/src/__tests__/stream.test.ts
@@ -695,9 +695,11 @@ describe("streams", function () {
 
 				streams[0].stream.routeSeekInterval = Number.MAX_VALUE; // disable seek so that we can check that the right amount of messages are sent below
 
-				const allWrites = streams.map((x) => collectDataWrites(x.stream));
 				streams[1].received = [];
 				streams[2].received = [];
+				const allWrites = streams.map((x) => collectDataWrites(x.stream));
+
+				await delay(3000);
 
 				// expect the data to be sent smartly
 				for (let i = 0; i < totalWrites; i++) {