@live-change/dao
Advanced tools
Comparing version 0.3.9 to 0.3.10
@@ -59,3 +59,3 @@ const Connection = require("./ReactiveConnection.js") | ||
dispose() { | ||
this.finished = true | ||
super.dispose() | ||
this.handleDisconnect() | ||
@@ -62,0 +62,0 @@ this.emit('close') |
@@ -126,2 +126,4 @@ const EventEmitter = require("./EventEmitter.js") | ||
this.activeTimeouts = new Set() | ||
this.autoReconnect = true | ||
@@ -177,3 +179,4 @@ | ||
if (settings.requestTimeout && settings.requestTimeout < Infinity) { | ||
setTimeout(() => { | ||
const timeout = setTimeout(() => { | ||
this.activeTimeouts.delete(timeout) | ||
let waiting = this.waitingRequests.get(msg.requestId) | ||
@@ -194,2 +197,3 @@ if (waiting) { | ||
}, settings.requestTimeout) | ||
this.activeTimeouts.add(timeout) | ||
} | ||
@@ -449,4 +453,10 @@ | ||
dispose() { | ||
console.log("DISPOSE REACTIVE CONNECTION") | ||
this.finished = true | ||
for(const timeout of this.activeTimeouts) clearTimeout(timeout) | ||
} | ||
} | ||
module.exports = Connection |
@@ -39,3 +39,3 @@ { | ||
}, | ||
"version": "0.3.9" | ||
"version": "0.3.10" | ||
} |
160905
4666