Skip to main content
Using Deno in production at your company? Earn free Deno merch.
Give us feedback
Go to Latest
class LimitedTransformStream
extends TransformStream<T, T>
import { LimitedTransformStream } from "";

A TransformStream that will only read & enqueue size amount of chunks.

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

import { LimitedTransformStream } from "./buffer.ts";
const res = await fetch("");
const parts = res.body!.pipeThrough(new LimitedTransformStream(50));


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