ldiamond/strom
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Types

Browse Source
This commit is contained in:
Jerry Kurian 2019-08-12 11:08:53 -04:00
parent e932adde67
commit 5112ee9540
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/functions/functions.spec.ts
View File

@ -1457,7 +1457,9 @@ test.cb("accumulator() rolling with key", t => {
t.deepEqual(flush, flushes[chunkIndex]); t.deepEqual(flush, flushes[chunkIndex]);
chunkIndex++; chunkIndex++;
}) })
.on("error", (e: any) => t.end) .on("error", (e: any) => {
t.end(e);
})
.on("end", () => { .on("end", () => {
t.end(); t.end();
}); });
@ -1501,7 +1503,9 @@ test.cb("accumulator() sliding", t => {
t.deepEqual(flush, flushes[chunkIndex]); t.deepEqual(flush, flushes[chunkIndex]);
chunkIndex++; chunkIndex++;
}) })
.on("error", (e: any) => t.end) .on("error", (e: any) => {
t.end(e);
})
.on("end", () => { .on("end", () => {
t.end(); t.end();
}); });
@ -1556,7 +1560,9 @@ test.cb("accumulator() sliding with key", t => {
t.deepEqual(flush, flushes[chunkIndex]); t.deepEqual(flush, flushes[chunkIndex]);
chunkIndex++; chunkIndex++;
}) })
.on("error", (e: any) => t.end) .on("error", (e: any) => {
t.end(e);
})
.on("end", () => { .on("end", () => {
t.end(); t.end();
}); });