1 | import { CancellablePromise } from '@theintern/common';
|
2 | import BaseChannel, { ChannelOptions } from './Base';
|
3 | export default class WebSocketChannel extends BaseChannel {
|
4 | timeout: number;
|
5 | protected _socket: WebSocket;
|
6 | protected _sendQueue: {
|
7 | [key: string]: {
|
8 | resolve: (value: any) => void;
|
9 | reject: (error: Error) => void;
|
10 | } | undefined;
|
11 | };
|
12 | protected _ready: CancellablePromise<any>;
|
13 | protected _sequence: number;
|
14 | constructor(options: ChannelOptions);
|
15 | protected _sendData(name: string, data: any): CancellablePromise<void>;
|
16 | protected _handleMessage(message: any): void;
|
17 | protected _handleError(error: Error): void;
|
18 | }
|