@@ -216,7 +216,7 @@ module.exports = function (server, config) {
216
216
client . once ( 'connect' , function ( ) {
217
217
done ( new Error ( 'Should not emit connect' ) ) ;
218
218
} ) ;
219
- client . once ( 'error' , function ( /*error*/ ) {
219
+ client . once ( 'error' , function ( /* error */ ) {
220
220
// to do
221
221
// check for error message
222
222
// and validate it is the expected one
@@ -263,7 +263,7 @@ module.exports = function (server, config) {
263
263
264
264
server . once ( 'client' , function ( serverClient ) {
265
265
serverClient . on ( 'subscribe' , function ( ) {
266
- serverClient . on ( 'publish' , function ( /*packet*/ ) {
266
+ serverClient . on ( 'publish' , function ( ) {
267
267
done ( ) ;
268
268
} ) ;
269
269
} ) ;
@@ -311,7 +311,7 @@ module.exports = function (server, config) {
311
311
client . publish ( 'test' , 'test' , { qos : 1 } , function ( ) {
312
312
client . end ( ) ;
313
313
} ) ;
314
- client . on ( 'message' , function ( /*t, p, packet*/ ) {
314
+ client . on ( 'message' , function ( ) {
315
315
done ( ) ;
316
316
} ) ;
317
317
} ) ;
@@ -566,7 +566,7 @@ module.exports = function (server, config) {
566
566
567
567
it ( 'should checkPing at keepalive interval' , function ( done ) {
568
568
var interval = 3 ,
569
- client = connect ( { keepalive : interval } ) ;
569
+ client = connect ( { keepalive : interval } ) ;
570
570
571
571
client . _checkPing = sinon . spy ( ) ;
572
572
@@ -634,7 +634,7 @@ module.exports = function (server, config) {
634
634
client . subscribe ( 'test' ) ;
635
635
636
636
server . once ( 'client' , function ( serverClient ) {
637
- serverClient . once ( 'subscribe' , function ( /*packet*/ ) {
637
+ serverClient . once ( 'subscribe' , function ( ) {
638
638
done ( ) ;
639
639
} ) ;
640
640
} ) ;
@@ -663,7 +663,7 @@ module.exports = function (server, config) {
663
663
var client = connect ( ) ,
664
664
subs = [ 'test1' , 'test2' ] ;
665
665
666
- client . once ( 'connect' , function ( /*args*/ ) {
666
+ client . once ( 'connect' , function ( ) {
667
667
client . subscribe ( subs ) ;
668
668
} ) ;
669
669
@@ -713,7 +713,7 @@ module.exports = function (server, config) {
713
713
topic = 'test' ,
714
714
opts = { qos : 1 } ;
715
715
716
- client . once ( 'connect' , function ( /*args*/ ) {
716
+ client . once ( 'connect' , function ( ) {
717
717
client . subscribe ( topic , opts ) ;
718
718
} ) ;
719
719
@@ -731,7 +731,7 @@ module.exports = function (server, config) {
731
731
var client = connect ( ) ,
732
732
topic = 'test' ;
733
733
734
- client . once ( 'connect' , function ( /*args*/ ) {
734
+ client . once ( 'connect' , function ( ) {
735
735
client . subscribe ( topic , { qos : 2 } , function ( err , granted ) {
736
736
if ( err ) {
737
737
done ( err ) ;
@@ -785,7 +785,7 @@ module.exports = function (server, config) {
785
785
} ) ;
786
786
787
787
server . once ( 'client' , function ( serverClient ) {
788
- serverClient . on ( 'subscribe' , function ( /*packet*/ ) {
788
+ serverClient . on ( 'subscribe' , function ( ) {
789
789
serverClient . publish ( testPacket ) ;
790
790
} ) ;
791
791
} ) ;
@@ -794,12 +794,12 @@ module.exports = function (server, config) {
794
794
it ( 'should support binary data' , function ( done ) {
795
795
var client = connect ( { encoding : 'binary' } ) ,
796
796
testPacket = {
797
- topic : 'test' ,
798
- payload : 'message' ,
799
- retain : true ,
800
- qos : 1 ,
801
- messageId : 5
802
- } ;
797
+ topic : 'test' ,
798
+ payload : 'message' ,
799
+ retain : true ,
800
+ qos : 1 ,
801
+ messageId : 5
802
+ } ;
803
803
804
804
client . subscribe ( testPacket . topic ) ;
805
805
client . once ( 'message' ,
@@ -812,7 +812,7 @@ module.exports = function (server, config) {
812
812
} ) ;
813
813
814
814
server . once ( 'client' , function ( serverClient ) {
815
- serverClient . on ( 'subscribe' , function ( /*packet*/ ) {
815
+ serverClient . on ( 'subscribe' , function ( ) {
816
816
serverClient . publish ( testPacket ) ;
817
817
} ) ;
818
818
} ) ;
@@ -840,7 +840,7 @@ module.exports = function (server, config) {
840
840
} ) ;
841
841
842
842
server . once ( 'client' , function ( serverClient ) {
843
- serverClient . on ( 'subscribe' , function ( /*packet*/ ) {
843
+ serverClient . on ( 'subscribe' , function ( ) {
844
844
serverClient . publish ( testPacket ) ;
845
845
} ) ;
846
846
} ) ;
@@ -868,7 +868,7 @@ module.exports = function (server, config) {
868
868
} ) ;
869
869
870
870
server . once ( 'client' , function ( serverClient ) {
871
- serverClient . on ( 'subscribe' , function ( /*packet*/ ) {
871
+ serverClient . on ( 'subscribe' , function ( ) {
872
872
serverClient . publish ( testPacket ) ;
873
873
// twice, should be ignored
874
874
serverClient . publish ( testPacket ) ;
@@ -879,12 +879,12 @@ module.exports = function (server, config) {
879
879
it ( 'should support chinese topic' , function ( done ) {
880
880
var client = connect ( { encoding : 'binary' } ) ,
881
881
testPacket = {
882
- topic : '国' ,
883
- payload : 'message' ,
884
- retain : true ,
885
- qos : 1 ,
886
- messageId : 5
887
- } ;
882
+ topic : '国' ,
883
+ payload : 'message' ,
884
+ retain : true ,
885
+ qos : 1 ,
886
+ messageId : 5
887
+ } ;
888
888
889
889
client . subscribe ( testPacket . topic ) ;
890
890
client . once ( 'message' ,
@@ -897,7 +897,7 @@ module.exports = function (server, config) {
897
897
} ) ;
898
898
899
899
server . once ( 'client' , function ( serverClient ) {
900
- serverClient . on ( 'subscribe' , function ( /*packet*/ ) {
900
+ serverClient . on ( 'subscribe' , function ( ) {
901
901
serverClient . publish ( testPacket ) ;
902
902
} ) ;
903
903
} ) ;
@@ -916,7 +916,7 @@ module.exports = function (server, config) {
916
916
} ) ;
917
917
918
918
server . once ( 'client' , function ( serverClient ) {
919
- serverClient . once ( 'subscribe' , function ( /*packet*/ ) {
919
+ serverClient . once ( 'subscribe' , function ( ) {
920
920
serverClient . publish ( {
921
921
topic : test_topic ,
922
922
payload : test_message ,
@@ -934,12 +934,12 @@ module.exports = function (server, config) {
934
934
test_message = 'message' ,
935
935
mid = 50 ;
936
936
937
- client . once ( 'connect' , function ( /*args*/ ) {
937
+ client . once ( 'connect' , function ( ) {
938
938
client . subscribe ( test_topic , { qos : 1 } ) ;
939
939
} ) ;
940
940
941
941
server . once ( 'client' , function ( serverClient ) {
942
- serverClient . once ( 'subscribe' , function ( /*packet*/ ) {
942
+ serverClient . once ( 'subscribe' , function ( ) {
943
943
serverClient . publish ( {
944
944
topic : test_topic ,
945
945
payload : test_message ,
@@ -966,7 +966,7 @@ module.exports = function (server, config) {
966
966
} ) ;
967
967
968
968
server . once ( 'client' , function ( serverClient ) {
969
- serverClient . once ( 'subscribe' , function ( /*packet*/ ) {
969
+ serverClient . once ( 'subscribe' , function ( ) {
970
970
serverClient . publish ( {
971
971
topic : test_topic ,
972
972
payload : test_message ,
@@ -975,7 +975,7 @@ module.exports = function (server, config) {
975
975
} ) ;
976
976
} ) ;
977
977
978
- serverClient . once ( 'pubcomp' , function ( /*packet*/ ) {
978
+ serverClient . once ( 'pubcomp' , function ( ) {
979
979
done ( ) ;
980
980
} ) ;
981
981
} ) ;
0 commit comments