fix(webSocket): return the correct type for WebSocketSubject `multi…

…plex` method(#6232) * chore: update type for multiplex operator * chore: update api_guard for websocket
ReactiveX · Apr 20, 2021 · 33383b8 · 33383b8
1 parent 45e6c6a
commit 33383b8
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/api_guard/dist/types/webSocket/index.d.ts b/api_guard/dist/types/webSocket/index.d.ts
@@ -3,7 +3,7 @@ export declare function webSocket<T>(urlConfigOrSource: string | WebSocketSubjec
 export declare class WebSocketSubject<T> extends AnonymousSubject<T> {
     constructor(urlConfigOrSource: string | WebSocketSubjectConfig<T> | Observable<T>, destination?: Observer<T>);
     lift<R>(operator: Operator<T, R>): WebSocketSubject<R>;
-    multiplex(subMsg: () => any, unsubMsg: () => any, messageFilter: (value: T) => boolean): Observable<any>;
+    multiplex(subMsg: () => any, unsubMsg: () => any, messageFilter: (value: T) => boolean): Observable<T>;
     unsubscribe(): void;
 }
 

diff --git a/src/internal/observable/dom/WebSocketSubject.ts b/src/internal/observable/dom/WebSocketSubject.ts
@@ -222,7 +222,7 @@ export class WebSocketSubject<T> extends AnonymousSubject<T> {
    */
   multiplex(subMsg: () => any, unsubMsg: () => any, messageFilter: (value: T) => boolean) {
     const self = this;
-    return new Observable((observer: Observer<any>) => {
+    return new Observable((observer: Observer<T>) => {
       try {
         self.next(subMsg());
       } catch (err) {