code/bybit-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

misc

Browse Source
This commit is contained in:
CryptoCompiler
2021-01-22 00:16:23 +00:00
committed by GitHub
parent 4f7d593fe4
commit be6e344c8f
1 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/websocket-client.ts
View File

@@ -45,7 +45,6 @@ export class WebsocketClient extends EventEmitter {
super(); super();
this.logger = logger || DefaultLogger; this.logger = logger || DefaultLogger;
this.readyState = READY_STATE_INITIAL; this.readyState = READY_STATE_INITIAL;
this.pingInterval = undefined; this.pingInterval = undefined;
this.pongTimeout = undefined; this.pongTimeout = undefined;
@@ -60,7 +59,6 @@ export class WebsocketClient extends EventEmitter {
this.client = new InverseClient(undefined, undefined, this.options.livenet, this.options.restOptions, this.options.requestOptions); this.client = new InverseClient(undefined, undefined, this.options.livenet, this.options.restOptions, this.options.requestOptions);
this._subscriptions = new Set(); this._subscriptions = new Set();
this._connect(); this._connect();
} }
@@ -101,7 +99,6 @@ export class WebsocketClient extends EventEmitter {
const authParams = await this._authenticate(); const authParams = await this._authenticate();
const url = this._getWsUrl() + authParams; const url = this._getWsUrl() + authParams;
const ws = new WebSocket(url); const ws = new WebSocket(url);
ws.onopen = this._wsOpenHandler.bind(this); ws.onopen = this._wsOpenHandler.bind(this);
@@ -110,7 +107,7 @@ export class WebsocketClient extends EventEmitter {
ws.onclose = this._wsCloseHandler.bind(this); ws.onclose = this._wsCloseHandler.bind(this);
this.ws = ws; this.ws = ws;
} catch (err) { } catch (err) {
this.logger.error('Connection failed: ', err); this.logger.error('Connection failed: ', err);
this._reconnect(this.options.reconnectTimeout); this._reconnect(this.options.reconnectTimeout);