language-servers/deno
1
0
Fork 0
mirror of https://github.com/denoland/deno.git synced 2025-10-01 14:41:15 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

fix(std/async): make pooledMap() errors catchable (#9217)

Browse source
This commit is contained in:
Nayeem Rahman 2021-01-22 11:45:29 +00:00 • committed by GitHub
parent 1a9209d1e3
commit 1518fabfbb
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 62 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

28
std/async/pool_test.ts
View file

@ -1,6 +1,12 @@
// Copyright 2018-2021 the Deno authors. All rights reserved. MIT license.
import { delay } from "./delay.ts";
import { pooledMap } from "./pool.ts";
import { assert } from "../testing/asserts.ts";
import {
assert,
assertEquals,
assertStringIncludes,
assertThrowsAsync,
} from "../testing/asserts.ts";
Deno.test("[async] pooledMap", async function (): Promise<void> {
const start = new Date();
@ -17,4 +23,22 @@ Deno.test("[async] pooledMap", async function (): Promise<void> {
assert(diff < 3000);
});
export {};
Deno.test("[async] pooledMap errors", async function (): Promise<void> {
async function mapNumber(n: number): Promise<number> {
if (n <= 2) {
throw new Error(`Bad number: ${n}`);
}
await delay(100);
return n;
}
const mappedNumbers: number[] = [];
const error = await assertThrowsAsync(async () => {
for await (const m of pooledMap(3, [1, 2, 3, 4], mapNumber)) {
mappedNumbers.push(m);
}
}, AggregateError) as AggregateError;
assertEquals(mappedNumbers, [3]);
assertEquals(error.errors.length, 2);
assertStringIncludes(error.errors[0].stack, "Error: Bad number: 1");
assertStringIncludes(error.errors[1].stack, "Error: Bad number: 2");
});