!@thi.ng/transducers-async

!npm downloads

> [!NOTE]
> This is one of 214 standalone projects, maintained as part
> of the @thi.ng/umbrella monorepo
> and anti-framework.
>
> 🚀 Please help me to work full-time on these projects by sponsoring me on
> GitHub. Thank you! ❤️

- About
- Evaluators
- Generators & iterators
- Combinators
- Transducers
- Reducers
- Status
- Related packages
- Installation
- Dependencies
- Usage examples
- API
- Authors
- License

About

Async versions of various highly composable transducers, reducers and iterators. This is a support package for @thi.ng/transducers.

$3

- iterator()
- reduce()
- run()
- step()
- transduce()

$3

- asAsyncIterable()
- concat()
- events()
- raf()
- range()
- repeatedly()
- sidechain()
- source()
- zip()

$3

- merge()
- mult()
- pubsub()
- sync()
- syncRAF()

$3

- comp()
- filter()
- map()
- mapcat()
- multiplex()
- multiplexObj()
- partition()
- take()
- throttle()
- throttleTime()

$3

- push()

Status

ALPHA - bleeding edge / work-in-progress

Search or submit any issues for this package

Related packages

- @thi.ng/csp - Primitives & operators for Communicating Sequential Processes based on async/await and async iterables
- @thi.ng/fibers - Process hierarchies & operators for cooperative multitasking
- @thi.ng/rstream - Reactive streams & subscription primitives for constructing dataflow graphs / pipelines

Installation

``bash
yarn add @thi.ng/transducers-async
`

ESM import:

`ts
import * as txa from "@thi.ng/transducers-async";
`

Browser ESM import:

`html

`

JSDelivr documentation

For Node.js REPL:

`js
const txa = await import("@thi.ng/transducers-async");
`

Package sizes (brotli'd, pre-treeshake): ESM: 3.25 KB

Dependencies

- @thi.ng/api
- @thi.ng/buffers
- @thi.ng/checks
- @thi.ng/compose
- @thi.ng/errors
- @thi.ng/timestamp
- @thi.ng/transducers

Note: @thi.ng/api is in _most_ cases a type-only import (not used at runtime)

Usage examples

Two projects in this repo's
/examples
directory are using this package:

| Screenshot | Description | Live demo | Source |
|:---------------------------------------------------------------------------------------------------------------|:-----------------------------------------------------------------------------|:-------------------------------------------------|:------------------------------------------------------------------------------|
| | CSP channel-based event handling, async transducers & reactive UI components | Demo | Source |
| | Basic & barebones usage of async iterables in thi.ng/rdom | Demo | Source |

API

Generated API docs

TODO

Authors

- Karsten Schmidt

If this project contributes to an academic publication, please cite it as:

`bibtex
@misc{thing-transducers-async,
title = "@thi.ng/transducers-async",
author = "Karsten Schmidt",
note = "https://thi.ng/transducers-async",
year = 2018
}
``

License

© 2018 - 2026 Karsten Schmidt // Apache License 2.0