File tree Expand file tree Collapse file tree 1 file changed +5
-10
lines changed Expand file tree Collapse file tree 1 file changed +5
-10
lines changed Original file line number Diff line number Diff line change @@ -282,23 +282,18 @@ class SwarmExtension {
282
282
this . networker = networker
283
283
this . name = name
284
284
this . encoding = codecs ( ( opts && opts . encoding ) || 'binary' )
285
+ this . _peerExtensions = new Map ( )
286
+
285
287
this . onmessage = opts . onmessage
286
288
this . onerror = opts . onerror
287
- this . _peerExtensions = new Map ( )
288
289
}
289
290
290
291
_registerExtension ( peer ) {
291
292
peer . stream . extensions . exclusive = false
292
293
const peerExt = peer . stream . registerExtension ( this . name , {
293
- onmessage : message => {
294
- if ( ! this . onmessage ) return
295
- if ( this . encoding ) message = this . encoding . decode ( message )
296
- this . onmessage ( message , peer )
297
- } ,
298
- onerror : err => {
299
- if ( ! this . onerror ) return
300
- this . onerror ( err )
301
- }
294
+ encoding : this . encoding ,
295
+ onmessage : this . onmessage && ( message => this . onmessage ( message , peer ) ) ,
296
+ onerror : this . onerror && ( err => this . onerror ( err ) )
302
297
} )
303
298
this . _peerExtensions . set ( peer , peerExt )
304
299
}
You can’t perform that action at this time.
0 commit comments