fluencelabs/js-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/js-libp2p synced 2025-06-12 16:51:23 +00:00
Code Issues Projects Releases Wiki Activity

feat: abort all pending dials on stop

Browse Source
This commit is contained in:
Jacob Heun
2019-12-06 17:45:29 +01:00
parent 0a8f9f3238
commit 754fbc2d0b
4 changed files with 41 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/index.js
View File

@ -194,8 +194,15 @@ class Libp2p extends EventEmitter {
log('libp2p is stopping')
try {
this.pubsub && await this.pubsub.stop()
this._dht && await this._dht.stop()
await Promise.all([
this.pubsub && this.pubsub.stop(),
this._dht && this._dht.stop()
])
for (const dial of this.dialer.pendingDials.values()) {
dial.abort()
}
await this.transportManager.close()
await this.registrar.close()
} catch (err) {