-
Notifications
You must be signed in to change notification settings - Fork 3k
/
index.d.ts
23 lines (21 loc) · 1004 Bytes
/
index.d.ts
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
export declare function webSocket<T>(urlConfigOrSource: string | WebSocketSubjectConfig<T>): WebSocketSubject<T>;
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<T>;
unsubscribe(): void;
}
export interface WebSocketSubjectConfig<T> {
WebSocketCtor?: {
new (url: string, protocols?: string | string[]): WebSocket;
};
binaryType?: 'blob' | 'arraybuffer';
closeObserver?: NextObserver<CloseEvent>;
closingObserver?: NextObserver<void>;
deserializer?: (e: MessageEvent) => T;
openObserver?: NextObserver<Event>;
protocol?: string | Array<string>;
resultSelector?: (e: MessageEvent) => T;
serializer?: (value: T) => WebSocketMessage;
url: string;
}