transformerFromTransform | /src/transformers.ts | proc@0.20.22

x/proc/src/transformers.ts>transformerFromTransform

A high-level way to run child processes that is easy, flexible, powerful, and prevents resource leaks.

function transformerFromTransform

import { transformerFromTransform } from "https://deno.land/x/proc@0.20.22/src/transformers.ts";

transformerFromTransform<R, T>(transform: { writable: WritableStream<R>; readable: ReadableStream<T>; }): (items: AsyncIterable<R>) => AsyncIterable<T>

Convert a TransformStream into AsyncIterable. Errors occurring upstream are correctly propagated through the transformation.

Type Parameters

Parameters

transform: { writable: WritableStream<R>; readable: ReadableStream<T>; }

A TransformStream.

Returns

(items: AsyncIterable<R>) => AsyncIterable<T>

A transformer function.