fix(stream): connecting errors not being handled correctly (#92)

microwavekonijn · Dec 3, 2022 · 465b4e6 · 465b4e6
1 parent 5ec9b97
commit 465b4e6
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/src/client/census.client.ts b/src/client/census.client.ts
@@ -106,7 +106,7 @@ export class CensusClient extends EventEmitter<ClientEvents> {
    * Doom and destruction, WUHAHAHAHA!
    */
   destroy(): void {
-    this.streamManager?.disconnect();
+    this.streamManager.disconnect();
   }
 
   /**

diff --git a/src/stream/stream.client.ts b/src/stream/stream.client.ts
@@ -283,6 +283,7 @@ export class StreamClient extends EventEmitter<StreamClientEvents> {
    */
   private cleanupConnection(): void {
     this.connection?.removeAllListeners();
+    this.connection?.on('error', () => null);
   }
 
   /**
-Original file line number
+Diff line change
@@ Expand Up @@
        */
       private cleanupConnection(): void {
         this.connection?.removeAllListeners();
+        this.connection?.on('error', () => null);
       }
       /**
@@ Expand Down @@