fix: force messages to be provessed slowly to ensure topology

dao-xyz · Dec 14, 2023 · 8a2b69e · 8a2b69e
1 parent 12a203a
commit 8a2b69e
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/packages/transport/stream/src/__tests__/stream.test.ts b/packages/transport/stream/src/__tests__/stream.test.ts
@@ -742,6 +742,14 @@ describe("streams", function () {
 			});
 
 			it("messages are only sent once to each peer", async () => {
+				streams.forEach((stream) => {
+					const processFn = stream.stream.processMessage.bind(stream.stream);
+					stream.stream.processMessage = async (a, b, c) => {
+						await delay(200);
+						return processFn(a, b, c);
+					};
+				});
+
 				let totalWrites = 10;
 				expect(streams[0].ack).toHaveLength(0);