From 57dfaec4c98f13a09fcfa2541c21b163a30c11d2 Mon Sep 17 00:00:00 2001
From: Alex Potsides <alex@achingbrain.net>
Date: Wed, 17 May 2023 14:26:33 +0100
Subject: [PATCH] fix: handle thrown errors (#405)

The pipe can throw when errors occur so handle the errors.
---
 .../src/close-test.ts                                       | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/packages/interface-stream-muxer-compliance-tests/src/close-test.ts b/packages/interface-stream-muxer-compliance-tests/src/close-test.ts
index aceb203a8..e75d047e9 100644
--- a/packages/interface-stream-muxer-compliance-tests/src/close-test.ts
+++ b/packages/interface-stream-muxer-compliance-tests/src/close-test.ts
@@ -81,7 +81,7 @@ export default (common: TestSetup<StreamMuxerFactory>): void => {
         direction: 'inbound',
         onIncomingStream: (stream) => {
           openedStreams++
-          void pipe(stream, stream)
+          void pipe(stream, stream).catch(() => {})
         }
       })
 
@@ -124,7 +124,7 @@ export default (common: TestSetup<StreamMuxerFactory>): void => {
         direction: 'inbound',
         onIncomingStream: (stream) => {
           openedStreams++
-          void pipe(stream, stream)
+          void pipe(stream, stream).catch(() => {})
         }
       })
 
@@ -193,7 +193,7 @@ export default (common: TestSetup<StreamMuxerFactory>): void => {
       const listener = listenerFactory.createStreamMuxer({
         direction: 'inbound',
         onIncomingStream: (stream) => {
-          void pipe(stream, stream)
+          void pipe(stream, stream).catch(() => {})
         }
       })