@@ -428,38 +428,12 @@ describe('13. stream1.js', function () {
428428 } ) ;
429429 } ) ;
430430
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 ) {
456432 this . timeout ( 30000 ) ;
457433
458434 connection . should . be . ok ;
459435
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' ) ;
463437
464438 stream . on ( 'error' , function ( error ) {
465439 should . fail ( error , null , 'Error event should not be triggered' ) ;
@@ -478,9 +452,7 @@ describe('13. stream1.js', function () {
478452
479453 var testDone = 0 ;
480454 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' ) ;
484456
485457 query . on ( 'error' , function ( error ) {
486458 should . fail ( error , null , 'Error event should not be triggered' ) ;
0 commit comments