Skip to content
This repository was archived by the owner on Feb 12, 2024. It is now read-only.

Commit 60dc0db

Browse files
author
Alan Shaw
committed
fix: eventemitter memory leak warning
License: MIT Signed-off-by: Alan Shaw <[email protected]>
1 parent 8d29a5b commit 60dc0db

File tree

1 file changed

+14
-6
lines changed

1 file changed

+14
-6
lines changed

src/core/components/libp2p.js

+14-6
Original file line numberDiff line numberDiff line change
@@ -87,15 +87,23 @@ module.exports = function libp2p (self) {
8787
peerBook: self._peerInfoBook
8888
})
8989

90+
let discoveredPeers = []
91+
92+
const putAndDial = peerInfo => {
93+
self._peerInfoBook.put(peerInfo)
94+
self._libp2pNode.dial(peerInfo, () => {})
95+
}
96+
97+
self._libp2pNode.on('start', () => {
98+
discoveredPeers.forEach(putAndDial)
99+
discoveredPeers = []
100+
})
101+
90102
self._libp2pNode.on('peer:discovery', (peerInfo) => {
91-
const dial = () => {
92-
self._peerInfoBook.put(peerInfo)
93-
self._libp2pNode.dial(peerInfo, () => {})
94-
}
95103
if (self.isOnline()) {
96-
dial()
104+
putAndDial(peerInfo)
97105
} else {
98-
self._libp2pNode.once('start', dial)
106+
discoveredPeers.push(peerInfo)
99107
}
100108
})
101109

0 commit comments

Comments
 (0)