@@ -410,63 +410,7 @@ describe('13. stream1.js', function () {
410
410
} ) ;
411
411
} ) ;
412
412
413
- it ( '13.1.11 stream stress test' , function ( done ) {
414
-
415
- var stream = connection . queryStream ( 'SELECT employee_name FROM nodb_stream1 ORDER BY employee_name' ) ;
416
-
417
- stream . on ( 'error' , function ( error ) {
418
- should . fail ( error , null , 'Error event should not be triggered' ) ;
419
- } ) ;
420
-
421
- var counter = 0 ;
422
- var allData = [ ] ;
423
- stream . on ( 'data' , function ( data ) {
424
- should . exist ( data ) ;
425
- allData . push ( data ) ;
426
- counter ++ ;
427
- } ) ;
428
-
429
- stream . on ( 'end' , function ( ) {
430
- should . equal ( counter , rowsAmount ) ;
431
-
432
- var testDone = 0 ;
433
- var subTest = function ( callback ) {
434
- var query = connection . queryStream ( 'SELECT employee_name FROM nodb_stream1 ORDER BY employee_name' ) ;
435
-
436
- query . on ( 'error' , function ( error ) {
437
- should . fail ( error , null , 'Error event should not be triggered' ) ;
438
- } ) ;
439
-
440
- var testCounter = 0 ;
441
- var testData = [ ] ;
442
- query . on ( 'data' , function ( data ) {
443
- should . exist ( data ) ;
444
- testData . push ( data ) ;
445
- testCounter ++ ;
446
- } ) ;
447
-
448
- query . on ( 'end' , function ( ) {
449
- should . equal ( testCounter , rowsAmount ) ;
450
- should . deepEqual ( testData , allData ) ;
451
-
452
- testDone ++ ;
453
- callback ( ) ;
454
- } ) ;
455
- } ;
456
- var tests = [ ] ;
457
- var i ;
458
- for ( i = 0 ; i < 50 ; i ++ ) { // larger values can cause 'ORA-01000: maximum open cursors exceeded'
459
- tests . push ( subTest ) ;
460
- }
461
- async . parallel ( tests , function ( ) {
462
- should . equal ( testDone , tests . length ) ;
463
-
464
- done ( ) ;
465
- } ) ;
466
- } ) ;
467
- } ) ;
468
-
469
- it ( '13.1.12 should emit events in the correct order' , function ( done ) {
413
+ it ( '13.1.11 should emit events in the correct order' , function ( done ) {
470
414
var stream = connection . queryStream ( 'SELECT employee_name FROM nodb_stream1 WHERE rownum = 1' ) ;
471
415
var events = [ ] ;
472
416
0 commit comments