summaryrefslogtreecommitdiff
path: root/cli/bench/deno_tcp_proxy.ts
diff options
context:
space:
mode:
authorInteon <42113979+inteon@users.noreply.github.com>2021-04-08 18:04:02 +0200
committerGitHub <noreply@github.com>2021-04-08 18:04:02 +0200
commitd050b491b10fe37b4461b37c56028a14c8674c95 (patch)
tree47aa768f3027dff90ffd1aacdd267274610bf441 /cli/bench/deno_tcp_proxy.ts
parentc4b21fbff119a8ce006391d8fb7586877759bcef (diff)
fix(core): error handling in examples (#9867)
Diffstat (limited to 'cli/bench/deno_tcp_proxy.ts')
-rw-r--r--cli/bench/deno_tcp_proxy.ts14
1 files changed, 8 insertions, 6 deletions
diff --git a/cli/bench/deno_tcp_proxy.ts b/cli/bench/deno_tcp_proxy.ts
index 1a424cee5..bab8eac19 100644
--- a/cli/bench/deno_tcp_proxy.ts
+++ b/cli/bench/deno_tcp_proxy.ts
@@ -15,14 +15,16 @@ async function handle(conn: Deno.Conn): Promise<void> {
});
try {
await Promise.all([Deno.copy(conn, origin), Deno.copy(origin, conn)]);
- } catch (err) {
- if (err.message !== "read error" && err.message !== "write error") {
- throw err;
+ } catch (e) {
+ if (
+ !(e instanceof Deno.errors.BrokenPipe) &&
+ !(e instanceof Deno.errors.ConnectionReset)
+ ) {
+ throw e;
}
- } finally {
- conn.close();
- origin.close();
}
+ conn.close();
+ origin.close();
}
console.log(`Proxy listening on http://${addr}/`);