Package Exports
- @thi.ng/transducers-async
- @thi.ng/transducers-async/api
- @thi.ng/transducers-async/as-async
- @thi.ng/transducers-async/cat
- @thi.ng/transducers-async/comp
- @thi.ng/transducers-async/compr
- @thi.ng/transducers-async/concat
- @thi.ng/transducers-async/delayed
- @thi.ng/transducers-async/ensure
- @thi.ng/transducers-async/events
- @thi.ng/transducers-async/filter
- @thi.ng/transducers-async/intercept
- @thi.ng/transducers-async/iterator
- @thi.ng/transducers-async/map
- @thi.ng/transducers-async/mapcat
- @thi.ng/transducers-async/merge
- @thi.ng/transducers-async/mult
- @thi.ng/transducers-async/multiplex
- @thi.ng/transducers-async/multiplex-obj
- @thi.ng/transducers-async/partition
- @thi.ng/transducers-async/pubsub
- @thi.ng/transducers-async/push
- @thi.ng/transducers-async/raf
- @thi.ng/transducers-async/range
- @thi.ng/transducers-async/reduce
- @thi.ng/transducers-async/repeatedly
- @thi.ng/transducers-async/run
- @thi.ng/transducers-async/sidechain
- @thi.ng/transducers-async/source
- @thi.ng/transducers-async/step
- @thi.ng/transducers-async/sync
- @thi.ng/transducers-async/sync-raf
- @thi.ng/transducers-async/take
- @thi.ng/transducers-async/throttle
- @thi.ng/transducers-async/throttle-time
- @thi.ng/transducers-async/transduce
- @thi.ng/transducers-async/zip
Readme
[!NOTE] This is one of 210 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
Async versions of various highly composable transducers, reducers and iterators. This is a support package for @thi.ng/transducers.
Evaluators
Generators & iterators
Combinators
Transducers
comp()
filter()
map()
mapcat()
multiplex()
multiplexObj()
partition()
take()
throttle()
throttleTime()
Reducers
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
yarn add @thi.ng/transducers-async
ESM import:
import * as txa from "@thi.ng/transducers-async";
Browser ESM import:
<script type="module" src="https://esm.run/@thi.ng/transducers-async"></script>
For Node.js REPL:
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
TODO
Authors
If this project contributes to an academic publication, please cite it as:
@misc{thing-transducers-async,
title = "@thi.ng/transducers-async",
author = "Karsten Schmidt",
note = "https://thi.ng/transducers-async",
year = 2018
}
License
© 2018 - 2025 Karsten Schmidt // Apache License 2.0