We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ef8ada0 commit ccce096Copy full SHA for ccce096
jetstream/tests/next_test.ts
@@ -131,12 +131,15 @@ Deno.test("next - consumer not found", async () => {
131
132
const js = nc.jetstream();
133
const c = await js.consumers.get("A", "a");
134
+ (nc as NatsConnectionImpl).options.debug = true;
135
await c.delete();
136
+ console.log("----- waiting one second -----");
137
await delay(1000);
138
+ console.log("----- after one second -----");
139
140
const exited = assertRejects(
- async () => {
- await c.next({ expires: 1000 });
141
+ () => {
142
+ return c.next({ expires: 1000 });
143
},
144
Error,
145
"consumer not found",
0 commit comments