graceful destroy

5 years ago · eb2c7e0a8d
2 changed files with 2 additions and 0 deletions
--- a/index.js
+++ b/index.js
@ -171,6 +171,7 @@ class DHT extends EventEmitter {
  }

  destroy () {
+    if (this.destroyed) return
    this.destroyed = true
    this._io.destroy()
    clearInterval(this._tickInterval)
--- a/lib/io.js
+++ b/lib/io.js
@ -201,6 +201,7 @@ class IO {
  }

  send (buffer, peer) {
+    if (this._ctx.destroyed) return
    this.socket.send(buffer, 0, buffer.length, peer.port, peer.host)
  }