foster/denoland-deno
1
0
Fork 0
mirror of https://github.com/denoland/deno.git synced 2024-11-28 16:20:57 -05:00
Code Issues Packages 1 Wiki Activity

fix(ext/node): fix stream/promises export (#19820)

Browse source
This commit is contained in:
await-ovo 2023-07-17 21:10:34 +08:00 committed by GitHub
parent 306b51d772
commit 37241e9b1e
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
3 changed files with 29 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
cli/tests/integration/node_unit_tests.rs
View file

@ -73,6 +73,7 @@ util::unit_test_factory!(
process_test,
querystring_test,
readline_test,
stream_test,
string_decoder_test,
timers_test,
tls_test,

25
cli/tests/unit_node/stream_test.ts Normal file
View file

@ -0,0 +1,25 @@
// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.
import { assert } from "../../../test_util/std/testing/asserts.ts";
import { fromFileUrl, relative } from "../../../test_util/std/path/mod.ts";
import { pipeline } from "node:stream/promises";
import { createReadStream, createWriteStream } from "node:fs";
Deno.test("stream/promises pipeline", async () => {
const filePath = relative(
Deno.cwd(),
fromFileUrl(new URL("./testdata/lorem_ipsum.txt", import.meta.url)),
);
const input = createReadStream(filePath);
const output = createWriteStream("lorem_ipsum.txt.copy");
await pipeline(input, output);
const content = Deno.readTextFileSync("lorem_ipsum.txt.copy");
assert(content.startsWith("Lorem ipsum dolor sit amet"));
try {
Deno.removeSync("lorem_ipsum.txt.copy");
} catch {
// pass
}
});

4
ext/node/polyfills/stream/promises.mjs
View file

@ -1,7 +1,9 @@
// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.
// Copyright Joyent and Node contributors. All rights reserved. MIT license.
import { finished, pipeline } from "ext:deno_node/_stream.mjs";
import { Stream } from "ext:deno_node/_stream.mjs";
const { finished, pipeline } = Stream.promises;
export default {
finished,