Skip to content

Commit d50dde8

Browse files
committed
impossible flappers
1 parent d472f35 commit d50dde8

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

jetstream/tests/next_test.ts

+3
Original file line numberDiff line numberDiff line change
@@ -160,6 +160,7 @@ Deno.test("next - deleted consumer", async () => {
160160
const js = nc.jetstream();
161161
const c = await js.consumers.get("A", "a");
162162

163+
(nc as NatsConnectionImpl).options.debug = true;
163164
const exited = assertRejects(
164165
() => {
165166
return c.next({ expires: 4000 });
@@ -190,7 +191,9 @@ Deno.test("next - stream not found", async () => {
190191
const js = nc.jetstream();
191192
const c = await js.consumers.get("A", "a");
192193

194+
(nc as NatsConnectionImpl).options.debug = true;
193195
await jsm.streams.delete("A");
196+
await delay(1000);
194197

195198
await assertRejects(
196199
() => {

0 commit comments

Comments
 (0)