import * as proc from "https://deno.land/x/proc@0.20.36/legacy/deps.ts";
Provide help with asynchronous tasks like delays, debouncing, deferring, or pooling.
Classes
A variable-sized buffer of bytes with | |
BufWriter implements buffering for an deno.Writer object. If an error occurs writing to a Writer, no more data will be accepted and all subsequent writes, and flush(), will return the error. After all data has been written, the client should call the flush() method to guarantee all data has been forwarded to the underlying deno.Writer. | |
BufWriterSync implements buffering for a deno.WriterSync object. If an error occurs writing to a WriterSync, no more data will be accepted and all subsequent writes, and flush(), will return the error. After all data has been written, the client should call the flush() method to guarantee all data has been forwarded to the underlying deno.WriterSync. | |
Reader utility for combining multiple readers | |
The MuxAsyncIterator class multiplexes multiple async iterators into a single stream. It currently makes an assumption that the final result (the value returned and not yielded from the iterator) does not matter; if there is any result, it is discarded. | |
Reader utility for strings. | |
Writer utility for buffering string chunks. |
Functions
Make Promise abortable with the given signal. | |
Make AsyncIterable abortable with the given signal. | |
Make Promise abortable with the given signal. | |
Copy N size at the most. If read size is lesser than N, then returns nread | |
Create a promise which will be rejected with | |
Creates a debounced function that delays the given | |
Creates a Promise with the | |
Resolve a Promise after a given amount of milliseconds. | |
pooledMap transforms values from an (async) iterable into another async iterable. The transforms are done concurrently, with a max concurrency defined by the poolLimit. | |
Read delimited bytes from a Reader. | |
Read big endian 32bit integer from BufReader | |
Read strings line-by-line from a Reader. | |
Read big endian 64bit long from BufReader | |
Read a range of bytes from a file or other resource that is readable and seekable. The range start and end are inclusive of the bytes within that range. | |
Read a range of bytes synchronously from a file or other resource that is readable and seekable. The range start and end are inclusive of the bytes within that range. | |
Read big endian 16bit short from BufReader | |
Read Reader chunk by chunk, splitting based on delimiter. | |
Calls the given (possibly asynchronous) function up to | |
Slice number into 64bit big endian byte array | |
f tee | Branches the given async iterable into the n branches. |
Interfaces
A debounced function that will be delayed by a given | |
Result type returned by of BufReader.readLine(). | |