@@ -428,38 +428,12 @@ describe('13. stream1.js', function () {
428
428
} ) ;
429
429
} ) ;
430
430
431
- it ( '13.1.11 stream results with bulk size set' , function ( done ) {
432
- connection . should . be . ok ;
433
-
434
- var stream = connection . queryStream ( 'SELECT employees_name FROM nodb_employees' , [ ] , {
435
- streamNumRows : 1
436
- } ) ;
437
-
438
- stream . on ( 'error' , function ( error ) {
439
- should . fail ( error , null , 'Error event should not be triggered' ) ;
440
- } ) ;
441
-
442
- var counter = 0 ;
443
- stream . on ( 'data' , function ( data ) {
444
- should . exist ( data ) ;
445
- counter ++ ;
446
- } ) ;
447
-
448
- stream . on ( 'end' , function ( ) {
449
- should . equal ( counter , rowsAmount ) ;
450
-
451
- setTimeout ( done , 500 ) ;
452
- } ) ;
453
- } ) ;
454
-
455
- it ( '13.1.12 stream stress test' , function ( done ) {
431
+ it ( '13.1.11 stream stress test' , function ( done ) {
456
432
this . timeout ( 30000 ) ;
457
433
458
434
connection . should . be . ok ;
459
435
460
- var stream = connection . queryStream ( 'SELECT employees_name FROM nodb_employees' , [ ] , {
461
- streamNumRows : 1
462
- } ) ;
436
+ var stream = connection . queryStream ( 'SELECT employees_name FROM nodb_employees' ) ;
463
437
464
438
stream . on ( 'error' , function ( error ) {
465
439
should . fail ( error , null , 'Error event should not be triggered' ) ;
@@ -478,9 +452,7 @@ describe('13. stream1.js', function () {
478
452
479
453
var testDone = 0 ;
480
454
var subTest = function ( callback ) {
481
- var query = connection . queryStream ( 'SELECT employees_name FROM nodb_employees' , [ ] , {
482
- streamNumRows : Math . floor ( ( Math . random ( ) * ( 500 - 1 ) ) + 1 )
483
- } ) ;
455
+ var query = connection . queryStream ( 'SELECT employees_name FROM nodb_employees' ) ;
484
456
485
457
query . on ( 'error' , function ( error ) {
486
458
should . fail ( error , null , 'Error event should not be triggered' ) ;
0 commit comments