@socket-mesh/async-stream-emitter

An alternantive to EventEmitter using consumable streams.

v7.1.2 URL: https://unpkg.com/@socket-mesh/async-stream-emitter@7.1.2/index.js

Open Browse Files

iterable async stream event emitter for-await-of

@socket-mesh/stream-demux

A consumable stream demultiplexer.

v10.1.5 URL: https://unpkg.com/@socket-mesh/stream-demux@10.1.5/index.js

Open Browse Files

iterable async stream demux demultiplexer for-await-of

@ai-zen/async-queue

AsyncQueue is a TypeScript class that provides a simple asynchronous queue implementation. It implements the `Symbol.asyncIterator` interface, allowing it to be used in `for-await-of` loops. This enables one or multiple consumers to process items in the q

v1.3.1 URL: https://unpkg.com/@ai-zen/async-queue@1.3.1/dist/index.js

Open Browse Files

async queue async-queue typescript asynciterator iterator for-await-of concurrent competing-consumers pattern

iterified

Convert any callback-based sequence of values into a full-fledged async iterable

v1.2.5 URL: https://unpkg.com/iterified@1.2.5/dist/cjs/index.js

Open Browse Files

callbacks-promises-async-await iterable iterator async-generator async-iterable async-iterator async-iterable-utility promise for-await-of async-channels async-await callbacks lazy disposable typescript esm

@socket-mesh/writable-consumable-stream

An async stream which can be iterated over using a for-await-of loop.

v4.2.9 URL: https://unpkg.com/@socket-mesh/writable-consumable-stream@4.2.9/index.js

Open Browse Files

async generator stream data for-await-of