fluencelabs/js-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/js-libp2p synced 2025-05-21 14:41:22 +00:00
Code Issues Projects Releases Wiki Activity

chore: _isStarted is false when stop starts

Browse Source
This commit is contained in:
Vasco Santos 2020-09-23 11:19:59 +02:00
parent da5785d18e
commit 4848313cb3
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/index.js
View File

@ -247,6 +247,7 @@ class Libp2p extends EventEmitter {
log('libp2p is stopping') log('libp2p is stopping')
try { try {
this._isStarted = false
for (const service of this._discovery.values()) { for (const service of this._discovery.values()) {
service.removeListener('peer', this._onDiscoveryPeer) service.removeListener('peer', this._onDiscoveryPeer)
} }
@ -258,7 +259,6 @@ class Libp2p extends EventEmitter {
await this.peerStore.stop() await this.peerStore.stop()
await this.connectionManager.stop() await this.connectionManager.stop()
ping.unmount(this)
await Promise.all([ await Promise.all([
this.pubsub && this.pubsub.stop(), this.pubsub && this.pubsub.stop(),
this._dht && this._dht.stop(), this._dht && this._dht.stop(),
@ -267,6 +267,8 @@ class Libp2p extends EventEmitter {
await this.transportManager.close() await this.transportManager.close()
ping.unmount(this)
this.dialer.destroy() this.dialer.destroy()
} catch (err) { } catch (err) {
if (err) { if (err) {
@ -274,7 +276,6 @@ class Libp2p extends EventEmitter {
this.emit('error', err) this.emit('error', err)
} }
} }
this._isStarted = false
log('libp2p has stopped') log('libp2p has stopped')
} }