Stream.pipeline() does not call the callback on completion #34059

'use strict';

import {pipeline, Readable} from 'stream';
import {createWriteStream} from 'fs';

pipeline(
    Readable.from(['a', 'b', 'c', '\r\n']),
    process.stdout,
    (err) => {
        console.log('finish callback stdout');
    }
);

pipeline(
    Readable.from(['a', 'b', 'c', '\r\n']),
    createWriteStream('outfile.txt'),
    (err) => {
        console.log('finish callback file write stream');
    }
);