diff options
Diffstat (limited to 'tests/unit_node/stream_test.ts')
-rw-r--r-- | tests/unit_node/stream_test.ts | 25 |
1 files changed, 25 insertions, 0 deletions
diff --git a/tests/unit_node/stream_test.ts b/tests/unit_node/stream_test.ts new file mode 100644 index 000000000..ab81497d1 --- /dev/null +++ b/tests/unit_node/stream_test.ts @@ -0,0 +1,25 @@ +// Copyright 2018-2024 the Deno authors. All rights reserved. MIT license. + +import { assert } from "@test_util/std/assert/mod.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 + } +}); |