|
|
@ -91,12 +91,16 @@ function fromWritable(stream) {
|
|
|
|
// NOTE: The use of `var` is intentional, to make hoisting possible here; otherwise we'd have a broken cyclical reference
|
|
|
|
// NOTE: The use of `var` is intentional, to make hoisting possible here; otherwise we'd have a broken cyclical reference
|
|
|
|
var writable = wireUpWritableInterface(stream, {
|
|
|
|
var writable = wireUpWritableInterface(stream, {
|
|
|
|
onEnd: () => {
|
|
|
|
onEnd: () => {
|
|
|
|
|
|
|
|
debugWritable(`Underlying stream has reported a close event (upstreamHasEnded = ${upstreamHasEnded})`);
|
|
|
|
|
|
|
|
|
|
|
|
if (!upstreamHasEnded) {
|
|
|
|
if (!upstreamHasEnded) {
|
|
|
|
|
|
|
|
debugWritable(`Issuing happy abort on converted stream`);
|
|
|
|
convertedStream.abort(true, mostRecentSource);
|
|
|
|
convertedStream.abort(true, mostRecentSource);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
},
|
|
|
|
},
|
|
|
|
onError: (error) => {
|
|
|
|
onError: (error) => {
|
|
|
|
// Make sure we notify the pipeline, if any, by passing in the most recent source stream that we've seen.
|
|
|
|
// Make sure we notify the pipeline, if any, by passing in the most recent source stream that we've seen.
|
|
|
|
|
|
|
|
debugWritable(`Issuing error abort on converted stream due to: ${error.message}`);
|
|
|
|
convertedStream.abort(error, mostRecentSource);
|
|
|
|
convertedStream.abort(error, mostRecentSource);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
});
|
|
|
|
});
|
|
|
|