test flapping in CI

nats-io · May 2, 2024 · d1a3fe8 · d1a3fe8
1 parent f7c41a8
commit d1a3fe8
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/tests/resub_test.ts b/tests/resub_test.ts
@@ -16,6 +16,7 @@
 import { cleanup, setup } from "./helpers/mod.ts";
 import { NatsConnectionImpl } from "../nats-base-client/nats.ts";
 import {
+  assert,
   assertEquals,
   assertExists,
   fail,
@@ -117,6 +118,7 @@ Deno.test("resub - removes server interest", async () => {
       // nothing
     },
   });
+  await nc.flush();
 
   const nci = nc as NatsConnectionImpl;
   let sub = nci.protocol.subscriptions.all().find((s) => {
@@ -129,12 +131,13 @@ Deno.test("resub - removes server interest", async () => {
 
   // change it
   nci._resub(sub, "b");
+  await nc.flush();
 
   // make sure we don't find a
   sub = nci.protocol.subscriptions.all().find((s) => {
     return s.subject === "a";
   });
-  assertEquals(sub, undefined);
+  assert(sub === undefined);
 
   // make sure we find b
   sub = nci.protocol.subscriptions.all().find((s) => {