1'use strict'; 2 3const common = require('../common'); 4const { 5 Duplex, 6} = require('stream'); 7const { setTimeout } = require('timers/promises'); 8 9{ 10 class Foo extends Duplex { 11 async _final(callback) { 12 await setTimeout(common.platformTimeout(1)); 13 callback(); 14 } 15 16 _read() {} 17 } 18 19 const foo = new Foo(); 20 foo._write = common.mustCall((chunk, encoding, cb) => { 21 cb(); 22 }); 23 foo.end('test', common.mustCall()); 24 foo.on('error', common.mustNotCall()); 25} 26