default | /esm/queue.js | ayonli_jsext@v0.9.72

A JavaScript extension package for building strong and modern applications.

Latest

archive array augment bytes class cli collections dialog error external fastly filetype fs hash http json math module number object parallel path promise reader string uint8array workerd ws

index.js (default module)

AsyncFunction

AsyncGeneratorFunction

run

tar

run

EOL

md5

avg

sep

cwd

addUnhandledRejectionListener

env

AsyncGeneratorFunction

function default

import { default } from "https://deno.land/x/ayonli_jsext@v0.9.72/esm/queue.js";

default(handler, bufferSize?)

Processes data sequentially by the given handler function and prevents concurrency conflicts, it returns a Queue instance that we can push data into.

Examples

Example 1

import queue from "@ayonli/jsext/queue";

const list: string[] = [];
const q = queue(async (str: string) => {
    await Promise.resolve(null);
    list.push(str);
});

q.onError(err => {
    console.error(err);
})

await q.push("foo");
await q.push("foo");

console.log(list.length);
q.close();
// output:
// 2

The maximum capacity of the underlying channel, once reached, the push operation will block until there is new space available. By default, this option is not set and use a non-buffered channel instead.

optional

bufferSize = [UNSUPPORTED]

Examples

Parameters