@@ -6542,15 +6542,15 @@ const parse = function(){
6542
6542
} ) ;
6543
6543
}
6544
6544
if ( data !== undefined ) {
6545
- // Give a chance for events to be registered later
6546
- if ( typeof setImmediate === 'function' ) {
6547
- setImmediate ( function ( ) {
6548
- parser . write ( data ) ;
6549
- parser . end ( ) ;
6550
- } ) ;
6551
- } else {
6545
+ const writer = function ( ) {
6552
6546
parser . write ( data ) ;
6553
6547
parser . end ( ) ;
6548
+ } ;
6549
+ // Support Deno, Rollup doesnt provide a shim for setImmediate
6550
+ if ( typeof setImmediate === 'function' ) {
6551
+ setImmediate ( writer ) ;
6552
+ } else {
6553
+ setTimeout ( writer , 0 ) ;
6554
6554
}
6555
6555
}
6556
6556
return parser ;
@@ -6667,13 +6667,19 @@ const transform = function(){
6667
6667
const transformer = new Transformer ( options , handler ) ;
6668
6668
let error = false ;
6669
6669
if ( records ) {
6670
- setImmediate ( function ( ) {
6670
+ const writer = function ( ) {
6671
6671
for ( const record of records ) {
6672
6672
if ( error ) break ;
6673
6673
transformer . write ( record ) ;
6674
6674
}
6675
6675
transformer . end ( ) ;
6676
- } ) ;
6676
+ } ;
6677
+ // Support Deno, Rollup doesnt provide a shim for setImmediate
6678
+ if ( typeof setImmediate === 'function' ) {
6679
+ setImmediate ( writer ) ;
6680
+ } else {
6681
+ setTimeout ( writer , 0 ) ;
6682
+ }
6677
6683
}
6678
6684
if ( callback || options . consume ) {
6679
6685
const result = [ ] ;
@@ -7266,19 +7272,17 @@ const stringify = function(){
7266
7272
} ) ;
7267
7273
}
7268
7274
if ( data !== undefined ) {
7269
- // Give a chance for events to be registered later
7270
- if ( typeof setImmediate === 'function' ) {
7271
- setImmediate ( function ( ) {
7272
- for ( const record of data ) {
7273
- stringifier . write ( record ) ;
7274
- }
7275
- stringifier . end ( ) ;
7276
- } ) ;
7277
- } else {
7275
+ const writer = function ( ) {
7278
7276
for ( const record of data ) {
7279
7277
stringifier . write ( record ) ;
7280
7278
}
7281
7279
stringifier . end ( ) ;
7280
+ } ;
7281
+ // Support Deno, Rollup doesnt provide a shim for setImmediate
7282
+ if ( typeof setImmediate === 'function' ) {
7283
+ setImmediate ( writer ) ;
7284
+ } else {
7285
+ setTimeout ( writer , 0 ) ;
7282
7286
}
7283
7287
}
7284
7288
return stringifier ;
0 commit comments