@ -90,7 +90,7 @@ function fromWritable(stream) {
// NOTE: The use of `var` is intentional, to make hoisting possible here; otherwise we'd have a broken cyclical reference
var writable = wireUpWritableInterface(stream, {
onClose: () => {
onEnd: () => {
if (!upstreamHasEnded) {
convertedStream.abort(true);
}