diff --git a/packages/rxjs/src/internal/observable/dom/WebSocketSubject.ts b/packages/rxjs/src/internal/observable/dom/WebSocketSubject.ts index 26e9291f87..956e0884fe 100644 --- a/packages/rxjs/src/internal/observable/dom/WebSocketSubject.ts +++ b/packages/rxjs/src/internal/observable/dom/WebSocketSubject.ts @@ -150,7 +150,7 @@ const WEBSOCKETSUBJECT_INVALID_ERROR_OBJECT = export type WebSocketMessage = string | ArrayBuffer | Blob | ArrayBufferView; -export class WebSocketSubject extends Subject { +export class WebSocketSubject extends Observable { private _config!: WebSocketSubjectConfig; private _output: Subject; @@ -365,6 +365,5 @@ export class WebSocketSubject extends Subject { _socket.close(); } this._resetState(); - super.unsubscribe(); } }