@@ -58,7 +58,8 @@ function checkKeyContent(client, key, body, reqUid, callback) {
58
58
client . get ( key , undefined , reqUid , ( err , stream ) => {
59
59
const chunks = [ ]
60
60
if ( err ) {
61
- done ( err ) ;
61
+ callback ( err ) ;
62
+ return ;
62
63
} else {
63
64
stream . on ( 'data' , val => {
64
65
chunks . push ( val ) ;
@@ -326,15 +327,15 @@ const clientImmutableWithFailover = new Sproxy({
326
327
client . put ( upStream , upload . length , parameters , reqUid ,
327
328
( err , key ) => {
328
329
if ( err ) {
329
- done ( err ) ;
330
+ next ( err ) ;
330
331
return ;
331
332
}
332
333
savedKey = key ;
333
334
next ( ) ;
334
335
} ) ;
335
336
} ,
336
- _ => checkKeyContent ( client , savedKey , upload , reqUid , done ) ,
337
- ] ) ;
337
+ next => checkKeyContent ( client , savedKey , upload , reqUid , next ) ,
338
+ ] , done ) ;
338
339
} ) ;
339
340
340
341
it ( 'should be able to put more data to sproxyd using the same socket' , done => {
@@ -353,15 +354,15 @@ const clientImmutableWithFailover = new Sproxy({
353
354
async . series ( [
354
355
next => client . put ( upStream1 , upload . length , parameters , reqUid , ( err , key ) => {
355
356
if ( err ) {
356
- done ( err ) ;
357
+ next ( err ) ;
357
358
return ;
358
359
}
359
360
savedKey1 = key ;
360
361
next ( ) ;
361
362
} ) ,
362
363
next => client . put ( upStream2 , upload . length , parameters , reqUid , ( err , key ) => {
363
364
if ( err ) {
364
- done ( err ) ;
365
+ next ( err ) ;
365
366
return ;
366
367
}
367
368
savedKey2 = key ;
@@ -370,8 +371,8 @@ const clientImmutableWithFailover = new Sproxy({
370
371
// Get data for the first key and assert that it matches the original upload
371
372
next => checkKeyContent ( client , savedKey1 , upload , reqUid , next ) ,
372
373
// Get data for the second key and assert that it matches the original upload
373
- _ => checkKeyContent ( client , savedKey2 , upload , reqUid , done ) ,
374
- ] ) ;
374
+ next => checkKeyContent ( client , savedKey2 , upload , reqUid , next ) ,
375
+ ] , done ) ;
375
376
} ) ;
376
377
} ) ;
377
378
} ) ;
0 commit comments