Skip to main content
Module

std/streams/limited_transform_stream_test.ts

The Deno Standard Library
denoland/deno_std
Go to Latest
File
1234567891011121314151617181920212223242526272829303132
// Copyright 2018-2024 the Deno authors. All rights reserved. MIT license.
import { assertEquals, assertRejects } from "../assert/mod.ts";import { LimitedTransformStream } from "./limited_transform_stream.ts";
Deno.test("LimitedTransformStream", async function () {  const r = ReadableStream.from([    "foo",    "foo",    "foo",    "foo",    "foo",    "foo",  ]).pipeThrough(new LimitedTransformStream(3));
  const chunks = await Array.fromAsync(r);  assertEquals(chunks.length, 3);});
Deno.test("LimitedTransformStream handles error", async function () {  const r = ReadableStream.from([    "foo",    "foo",    "foo",    "foo",    "foo",    "foo",  ]).pipeThrough(new LimitedTransformStream(3, { error: true }));
  await assertRejects(async () => await Array.fromAsync(r), RangeError);});