Skip to content

Commit

Permalink
review comments
Browse files Browse the repository at this point in the history
  • Loading branch information
aricart committed May 11, 2022
1 parent 8b17907 commit 37bcbc8
Showing 1 changed file with 12 additions and 1 deletion.
13 changes: 12 additions & 1 deletion tests/jsm_test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -999,12 +999,23 @@ Deno.test("jsm - stream info subjects", async () => {
await js.publish(`${name}.a.b`);
await js.publish(`${name}.a.b.c`);

const si = await jsm.streams.info(name, { subjects_filter: `>` });
let si = await jsm.streams.info(name, { subjects_filter: `>` });
assertEquals(si.state.num_subjects, 3);
assert(si.state.subjects);
assertEquals(Object.keys(si.state.subjects).length, 3);
assertEquals(si.state.subjects[`${name}.a`], 1);
assertEquals(si.state.subjects[`${name}.a.b`], 1);
assertEquals(si.state.subjects[`${name}.a.b.c`], 1);

si = await jsm.streams.info(name, { subjects_filter: `${name}.a.>` });
assertEquals(si.state.num_subjects, 3);
assert(si.state.subjects);
assertEquals(Object.keys(si.state.subjects).length, 2);
assertEquals(si.state.subjects[`${name}.a.b`], 1);
assertEquals(si.state.subjects[`${name}.a.b.c`], 1);

si = await jsm.streams.info(name);
assertEquals(si.state.subjects, undefined);

await cleanup(ns, nc);
});

0 comments on commit 37bcbc8

Please sign in to comment.