From b71a85918815195a2a8ba070fb534e50938251bd Mon Sep 17 00:00:00 2001 From: Satya Rohith Date: Tue, 25 Jun 2024 15:06:40 +0530 Subject: test(node_compat): enable more stream-writable tests (#24328) --- .../parallel/test-stream-writable-final-async.js | 32 ++++++++++++++++++++++ 1 file changed, 32 insertions(+) create mode 100644 tests/node_compat/test/parallel/test-stream-writable-final-async.js (limited to 'tests/node_compat/test/parallel/test-stream-writable-final-async.js') diff --git a/tests/node_compat/test/parallel/test-stream-writable-final-async.js b/tests/node_compat/test/parallel/test-stream-writable-final-async.js new file mode 100644 index 000000000..c8fe2057b --- /dev/null +++ b/tests/node_compat/test/parallel/test-stream-writable-final-async.js @@ -0,0 +1,32 @@ +// deno-fmt-ignore-file +// deno-lint-ignore-file + +// Copyright Joyent and Node contributors. All rights reserved. MIT license. +// Taken from Node 18.12.1 +// This file is automatically generated by `tests/node_compat/runner/setup.ts`. Do not modify this file manually. + +'use strict'; + +const common = require('../common'); +const { + Duplex, +} = require('stream'); +const { setTimeout } = require('timers/promises'); + +{ + class Foo extends Duplex { + async _final(callback) { + await setTimeout(common.platformTimeout(1)); + callback(); + } + + _read() {} + } + + const foo = new Foo(); + foo._write = common.mustCall((chunk, encoding, cb) => { + cb(); + }); + foo.end('test', common.mustCall()); + foo.on('error', common.mustNotCall()); +} -- cgit v1.2.3