From faf0d7235ed89e74ce66ebf8d4c4898a9923838f Mon Sep 17 00:00:00 2001 From: Fang-Pen Lin Date: Mon, 17 Jul 2017 22:42:31 -0700 Subject: [PATCH] fix: Make WebSocketSubjectConfig a generic type --- src/observable/dom/WebSocketSubject.ts | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/observable/dom/WebSocketSubject.ts b/src/observable/dom/WebSocketSubject.ts index c315eadbbe..de38d4d4b6 100644 --- a/src/observable/dom/WebSocketSubject.ts +++ b/src/observable/dom/WebSocketSubject.ts @@ -10,10 +10,10 @@ import { tryCatch } from '../../util/tryCatch'; import { errorObject } from '../../util/errorObject'; import { assign } from '../../util/assign'; -export interface WebSocketSubjectConfig { +export interface WebSocketSubjectConfig { url: string; protocol?: string | Array; - resultSelector?: (e: MessageEvent) => T; + resultSelector?: (e: MessageEvent) => T; openObserver?: NextObserver; closeObserver?: NextObserver; closingObserver?: NextObserver; @@ -75,17 +75,17 @@ export class WebSocketSubject extends AnonymousSubject { * * socket$.next(JSON.stringify({ op: 'hello' })); * - * @param {string | WebSocketSubjectConfig} urlConfigOrSource the source of the websocket as an url or a structure defining the websocket object + * @param {string | WebSocketSubjectConfig} urlConfigOrSource the source of the websocket as an url or a structure defining the websocket object * @return {WebSocketSubject} * @static true * @name webSocket * @owner Observable */ - static create(urlConfigOrSource: string | WebSocketSubjectConfig): WebSocketSubject { + static create(urlConfigOrSource: string | WebSocketSubjectConfig): WebSocketSubject { return new WebSocketSubject(urlConfigOrSource); } - constructor(urlConfigOrSource: string | WebSocketSubjectConfig | Observable, destination?: Observer) { + constructor(urlConfigOrSource: string | WebSocketSubjectConfig | Observable, destination?: Observer) { if (urlConfigOrSource instanceof Observable) { super(destination, > urlConfigOrSource); } else {