Remove listeners from sockets on disconnect
This commit is contained in:
+1
-1
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "paravel",
|
"name": "paravel",
|
||||||
"version": "0.2.0",
|
"version": "0.2.1",
|
||||||
"description": "Yet another toolkit for nostr",
|
"description": "Yet another toolkit for nostr",
|
||||||
"repository": {
|
"repository": {
|
||||||
"type": "git",
|
"type": "git",
|
||||||
|
|||||||
+1
-1
@@ -30,7 +30,7 @@ export class Executor {
|
|||||||
},
|
},
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
publish(event, {verb = 'EVENT', onOk, onError}) {
|
publish(event, {verb = 'EVENT', onOk, onError} = {}) {
|
||||||
const okListener = (url, id, ...payload) => id === event.id && onOk(url, id, ...payload)
|
const okListener = (url, id, ...payload) => id === event.id && onOk(url, id, ...payload)
|
||||||
const errorListener = (url, id, ...payload) => id === event.id && onError(url, id, ...payload)
|
const errorListener = (url, id, ...payload) => id === event.id && onError(url, id, ...payload)
|
||||||
|
|
||||||
|
|||||||
@@ -75,6 +75,7 @@ export class Socket extends EventEmitter {
|
|||||||
|
|
||||||
// Avoid "WebSocket was closed before the connection was established"
|
// Avoid "WebSocket was closed before the connection was established"
|
||||||
this.ready.then(() => ws.close(), () => null)
|
this.ready.then(() => ws.close(), () => null)
|
||||||
|
this.ws.removeAllListeners()
|
||||||
this.ws = undefined
|
this.ws = undefined
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user