Skip to content

Commit 498cb24

Browse files
committed
Fix stream test
1 parent a0a1118 commit 498cb24

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

src/test/23-aql-queries-stream.ts

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,7 @@ describe34("AQL Stream queries", function () {
8383
);
8484
await Promise.all(
8585
cursors.map((c) =>
86-
(c as ArrayCursor).each(() => {
86+
(c as ArrayCursor).forEach(() => {
8787
count++;
8888
})
8989
)
@@ -103,8 +103,9 @@ describe34("AQL Stream queries", function () {
103103
// the read cursor should always win
104104
const c = await Promise.race([readCursor, writeCursor]);
105105
// therefore no document should have been written here
106-
const isOk = await c.every((d: any) => !d.hasOwnProperty("forbidden"));
107-
expect(isOk).to.equal(true);
106+
for await (const d of c) {
107+
expect(d).not.to.haveOwnProperty("forbidden");
108+
}
108109
});
109110
});
110111
});

0 commit comments

Comments
 (0)