iridium/neko
2
2
Fork 0
mirror of https://github.com/m1k1o/neko.git synced 2024-07-24 14:40:50 +12:00
Code Issues Packages Projects Releases Wiki Activity

reconnecter fix context.

Browse Source
This commit is contained in:
Miroslav Šedivý 2021-07-15 23:27:59 +02:00
parent da18d477e0
commit 78cefb95b7
1 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/component/utils/reconnecter.ts
View File

@ -57,8 +57,8 @@ export class Reconnecter extends EventEmitter<ReconnecterEvents> {
...config, ...config,
} }
this._conn.on('connect', this.onConnect) this._conn.on('connect', this.onConnect.bind(this))
this._conn.on('disconnect', this.onDisconnect) this._conn.on('disconnect', this.onDisconnect.bind(this))
} }
private onConnect() { private onConnect() {
@ -126,12 +126,7 @@ export class Reconnecter extends EventEmitter<ReconnecterEvents> {
this._open = true this._open = true
this.emit('open') this.emit('open')
this.connect()
this._conn.connect()
this._timeout = window.setTimeout(() => {
this._conn.disconnect()
this.reconnect()
}, this._config.timeout_ms)
} }
public close(error?: Error): void { public close(error?: Error): void {
@ -148,6 +143,11 @@ export class Reconnecter extends EventEmitter<ReconnecterEvents> {
} }
} }
public connect(): void {
this._conn.connect()
this._timeout = window.setTimeout(this.onDisconnect.bind(this), this._config.timeout_ms)
}
public reconnect(): void { public reconnect(): void {
if (this._connected) { if (this._connected) {
throw new Error('connection is already connected') throw new Error('connection is already connected')
@ -155,15 +155,15 @@ export class Reconnecter extends EventEmitter<ReconnecterEvents> {
this._total_reconnects++ this._total_reconnects++
if (this._config.max_reconnects < this._total_reconnects || this._total_reconnects < 0) { if (this._config.max_reconnects > this._total_reconnects || this._total_reconnects < 0) {
setTimeout(this._conn.connect, this._config.backoff_ms) setTimeout(this.connect.bind(this), this._config.backoff_ms)
} else { } else {
this.close(new Error('reconnection failed')) this.close(new Error('reconnection failed'))
} }
} }
public destroy() { public destroy() {
this._conn.off('connect', this.onConnect) this._conn.off('connect', this.onConnect.bind(this))
this._conn.off('disconnect', this.onDisconnect) this._conn.off('disconnect', this.onDisconnect.bind(this))
} }
} }