Skip to main content
Module

x/rx_webstreams/mod.ts

A deno module to provide rx-like functionalities based on webstreams, esp. transforms like `map()` by @codemonument
Go to Latest
import * as rxWebstreams from "https://deno.land/x/rx_webstreams@0.7.2/mod.ts";

Classes

Type R = The type which is emitted by this underlying source

Functions

Creates a TransformStream (Webstream) which transforms uint8Array chunks to a string. Detects input encoding automatically!

Creates a Source ReadableStream (Webstream) which opens a file for reading.

Creates a Source ReadableStream (Webstream) which opens a file for reading.

Creates a TransformStream (Webstream) which converts from one chunk format to another.

Creates a TransformStream (Webstream) which converts from one chunk format to another.

Creates a TransformStream (Webstream) which multiplexes multiple readable streams.

Creates a Target WritableStream (Webstream) which gets the chunks of a stream and calls the chunkCallback function

Creates a Source ReadableStream (Webstream) which opens a file for reading.

Creates a Source ReadableStream (Webstream) which generates timer events as chunks.

Creates a TransformStream (Webstream) validates the type of the input chunk via a zod validator