import * as msgpackRpc from "https://deno.land/x/msgpack_rpc@v4.0.1/deps.ts";
Namespaces
Utilities for working with the Streams API. |
Classes
A variable-sized buffer of bytes with | |
A transform stream that only transforms from the zero-indexed | |
Divide a stream into chunks delimited by a given byte sequence. | |
A TransformStream that will only read & enqueue | |
A TransformStream that will only read & enqueue | |
Transform a stream into a stream where each chunk is divided by a given delimiter. | |
Transform a stream into a stream where each chunk is divided by a newline,
be it |
Functions
Creates a Promise with the | |
Resolve a Promise after a given amount of milliseconds. | |
It encodes | |
Copies from | |
Merge multiple streams into a single one, taking order into account, and each stream will wait for a chunk to enqueue before the next stream can append another chunk. If a stream ends before other ones, the others will be cancelled. | |
Turns a Reader, | |
Turns a ReaderSync, | |
Merge multiple streams into a single one, not taking order into account. If a stream ends before other ones, the other will continue adding data, and the finished one will not add any more data. | |
Create a | |
Create a | |
Read Reader | |
Synchronously reads Reader | |
Create a | |
Create a | |
Convert the generator function into a TransformStream. | |
Create a | |
Write all the content of the array buffer ( | |
Synchronously write all the content of the array buffer ( | |
Create a | |
Merge multiple streams into a single one, taking order into account, and each stream will wait for a chunk to enqueue before the next stream can append another chunk. If a stream ends before other ones, the others will continue adding data in order, and the finished one will not add any more data. |
Type Aliases
Disposable has 'dispose()' method to dispose the resource | |
Disposition of the delimiter. |