File tree Expand file tree Collapse file tree 1 file changed +6
-6
lines changed Expand file tree Collapse file tree 1 file changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -330,7 +330,7 @@ function MqttClient (streamBuilder, options) {
330
330
331
331
// Send queued packets
332
332
this . on ( 'connect' , function ( ) {
333
- const queue = this . queue
333
+ const queue = that . queue
334
334
335
335
function deliver ( ) {
336
336
const entry = queue . shift ( )
@@ -372,23 +372,23 @@ function MqttClient (streamBuilder, options) {
372
372
373
373
this . on ( 'close' , function ( ) {
374
374
debug ( 'close :: connected set to `false`' )
375
- this . connected = false
375
+ that . connected = false
376
376
377
377
debug ( 'close :: clearing connackTimer' )
378
- clearTimeout ( this . connackTimer )
378
+ clearTimeout ( that . connackTimer )
379
379
380
380
debug ( 'close :: clearing ping timer' )
381
381
if ( that . pingTimer !== null ) {
382
382
that . pingTimer . clear ( )
383
383
that . pingTimer = null
384
384
}
385
385
386
- if ( this . topicAliasRecv ) {
387
- this . topicAliasRecv . clear ( )
386
+ if ( that . topicAliasRecv ) {
387
+ that . topicAliasRecv . clear ( )
388
388
}
389
389
390
390
debug ( 'close :: calling _setupReconnect' )
391
- this . _setupReconnect ( )
391
+ that . _setupReconnect ( )
392
392
} )
393
393
EventEmitter . call ( this )
394
394
You can’t perform that action at this time.
0 commit comments