fix(WebSocketSubject): Closes socket when closing socket subject obse…

…rver (ReactiveX#5312)
bever1337 · Sep 29, 2022 · b08e116 · b08e116
1 parent afac3d5
commit b08e116
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/internal/observable/dom/WebSocketSubject.ts b/src/internal/observable/dom/WebSocketSubject.ts
@@ -359,7 +359,12 @@ export class WebSocketSubject<T> extends AnonymousSubject<T> {
         const { deserializer } = this._config;
         observer.next(deserializer!(e));
       } catch (err) {
+        this._resetState();
         observer.error(err);
+        if (socket && (socket.readyState === 1 || socket.readyState === 0)) {
+          // close the socket after the observer so additional WebSocket events do not race to end the observer
+          socket.close();
+        }
       }
     };
   }