File tree Expand file tree Collapse file tree 3 files changed +4
-4
lines changed Expand file tree Collapse file tree 3 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -86,8 +86,8 @@ const queue = Queue.channels(3)
86
86
const waiting = queue . waiting . length ;
87
87
console . log ( `Done: ${ res . name } , count:${ count } , waiting: ${ waiting } ` ) ;
88
88
} )
89
- . success ( res => console . log ( `Success: ${ res . name } ` ) )
90
- . failure ( err => console . log ( `Failure: ${ err } ` ) )
89
+ . success ( ( res ) => console . log ( `Success: ${ res . name } ` ) )
90
+ . failure ( ( err ) => console . log ( `Failure: ${ err } ` ) )
91
91
. drain ( ( ) => console . log ( 'Queue drain' ) ) ;
92
92
93
93
for ( let i = 0 ; i < 10 ; i ++ ) {
Original file line number Diff line number Diff line change @@ -123,7 +123,7 @@ const queue = Queue.channels(3)
123
123
. wait ( 4000 )
124
124
. timeout ( 5000 )
125
125
. process ( job )
126
- . success ( task => console . log ( `Success: ${ task . name } ` ) )
126
+ . success ( ( task ) => console . log ( `Success: ${ task . name } ` ) )
127
127
. failure ( ( err , task ) => console . log ( `Failure: ${ err } ${ task . name } ` ) )
128
128
. drain ( ( ) => console . log ( 'Queue drain' ) ) ;
129
129
Original file line number Diff line number Diff line change @@ -144,7 +144,7 @@ const queue = Queue.channels(3)
144
144
. wait ( 4000 )
145
145
. timeout ( 5000 )
146
146
. process ( job )
147
- . success ( task => console . log ( `Success: ${ task . name } ` ) )
147
+ . success ( ( task ) => console . log ( `Success: ${ task . name } ` ) )
148
148
. failure ( ( err , task ) => console . log ( `Failure: ${ err } ${ task . name } ` ) )
149
149
. pause ( ) ;
150
150
You can’t perform that action at this time.
0 commit comments