Skip to main content
Deno 2 is finally here 🎉️
Learn more
Module

x/proc/tests/deps/streams.ts>LimitedBytesTransformStream

A better way to work with processes in Deno.
Go to Latest
class LimitedBytesTransformStream
extends TransformStream<Uint8Array, Uint8Array>
import { LimitedBytesTransformStream } from "https://deno.land/x/proc@0.21.1/tests/deps/streams.ts";

A TransformStream that will only read & enqueue size amount of bytes. This operation is chunk based and not BYOB based, and as such will read more than needed.

if options.error is set, then instead of terminating the stream, an error will be thrown.

import { LimitedBytesTransformStream } from "https://deno.land/std@0.224.0/streams/limited_bytes_transform_stream.ts";
const res = await fetch("https://example.com");
const parts = res.body!
  .pipeThrough(new LimitedBytesTransformStream(512 * 1024));

Constructors

new
LimitedBytesTransformStream(size: number, options?: { error?: boolean; })