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

fix: stop discoveries (#530)

Browse Source 
* fix: stop discoveries

* test: add discovery stop test

* chore: fix lint

Co-authored-by: Jacob Heun <jacobheun@gmail.com>
This commit is contained in:
Alan Shaw
2020-01-07 15:27:32 +00:00
committed by Jacob Heun
parent 2f2ba420ef
commit 4222c49556
2 changed files with 33 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/index.js
View File

@ -218,7 +218,14 @@ class Libp2p extends EventEmitter {
log('libp2p is stopping')
try {
for (const service of this._discovery.values()) {
service.removeListener('peer', this._onDiscoveryPeer)
}
await Promise.all(Array.from(this._discovery.values(), s => s.stop()))
this.connectionManager.stop()
await Promise.all([
this.pubsub && this.pubsub.stop(),
this._dht && this._dht.stop(),