@@ -313,9 +313,8 @@ function newStreamWritableFromWritableStream(writableStream, options = kEmptyObj
|
313 | 313 | |
314 | 314 | writev(chunks, callback) { |
315 | 315 | function done(error) { |
316 | | -error = error.filter((e) => e); |
317 | 316 | try { |
318 | | -callback(error.length === 0 ? undefined : error); |
| 317 | +callback(error); |
319 | 318 | } catch (error) { |
320 | 319 | // In a next tick because this is happening within |
321 | 320 | // a promise context, and if there are any errors |
@@ -333,7 +332,7 @@ function newStreamWritableFromWritableStream(writableStream, options = kEmptyObj
|
333 | 332 | SafePromiseAll( |
334 | 333 | chunks, |
335 | 334 | (data) => writer.write(data.chunk)), |
336 | | -done, |
| 335 | +() => done(), |
337 | 336 | done); |
338 | 337 | }, |
339 | 338 | done); |
@@ -775,9 +774,8 @@ function newStreamDuplexFromReadableWritablePair(pair = kEmptyObject, options =
|
775 | 774 | |
776 | 775 | writev(chunks, callback) { |
777 | 776 | function done(error) { |
778 | | -error = error.filter((e) => e); |
779 | 777 | try { |
780 | | -callback(error.length === 0 ? undefined : error); |
| 778 | +callback(error); |
781 | 779 | } catch (error) { |
782 | 780 | // In a next tick because this is happening within |
783 | 781 | // a promise context, and if there are any errors |
@@ -795,7 +793,7 @@ function newStreamDuplexFromReadableWritablePair(pair = kEmptyObject, options =
|
795 | 793 | SafePromiseAll( |
796 | 794 | chunks, |
797 | 795 | (data) => writer.write(data.chunk)), |
798 | | -done, |
| 796 | +() => done(), |
799 | 797 | done); |
800 | 798 | }, |
801 | 799 | done); |
|