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)
8686 const waiting = queue . waiting . length ;
8787 console . log ( `Done: ${ res . name } , count:${ count } , waiting: ${ waiting } ` ) ;
8888 } )
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 } ` ) )
9191 . drain ( ( ) => console . log ( 'Queue drain' ) ) ;
9292
9393for ( 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)
123123 . wait ( 4000 )
124124 . timeout ( 5000 )
125125 . process ( job )
126- . success ( task => console . log ( `Success: ${ task . name } ` ) )
126+ . success ( ( task ) => console . log ( `Success: ${ task . name } ` ) )
127127 . failure ( ( err , task ) => console . log ( `Failure: ${ err } ${ task . name } ` ) )
128128 . drain ( ( ) => console . log ( 'Queue drain' ) ) ;
129129
Original file line number Diff line number Diff line change @@ -144,7 +144,7 @@ const queue = Queue.channels(3)
144144 . wait ( 4000 )
145145 . timeout ( 5000 )
146146 . process ( job )
147- . success ( task => console . log ( `Success: ${ task . name } ` ) )
147+ . success ( ( task ) => console . log ( `Success: ${ task . name } ` ) )
148148 . failure ( ( err , task ) => console . log ( `Failure: ${ err } ${ task . name } ` ) )
149149 . pause ( ) ;
150150
You can’t perform that action at this time.
0 commit comments