We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6708f3c commit 778f57fCopy full SHA for 778f57f
index.js
@@ -93,22 +93,18 @@ class CorestoreNetworker extends Nanoresource {
93
else flushedProm.catch(() => {})
94
}
95
96
- async _leave (discoveryKey) {
+ _leave (discoveryKey) {
97
const keyString = toString(discoveryKey)
98
const keyBuf = (discoveryKey instanceof Buffer) ? discoveryKey : Buffer.from(discoveryKey, 'hex')
99
100
this._joined.delete(keyString)
101
102
- await new Promise((resolve, reject) => {
+ return new Promise((resolve, reject) => {
103
this.swarm.leave(keyBuf, err => {
104
if (err) return reject(err)
105
return resolve()
106
})
107
108
-
109
- for (const stream of this.streams) {
110
- stream.close(keyBuf)
111
- }
112
113
114
_registerAllExtensions (peer) {
0 commit comments