159 lines
55 KiB
Markdown
159 lines
55 KiB
Markdown
# @suaveplan/streams - WHATWG-Streams-based primitives: backpressure-first transforms, zero-copy Uint8Array operations, AbortSignal integration, OTel instrumentation
|
|
|
|
## Summary
|
|
|
|
WHATWG-Streams-based primitives: backpressure-first transforms, zero-copy `Uint8Array` operations, `AbortSignal` integration end-to-end, structured errors, OTel instrumentation, and property-based invariant tests.
|
|
|
|
<!-- begin:auto-docs -->
|
|
## Documentation tree
|
|
|
|
- [transform](./src/base/transform/transform.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [transform](./src/base/transform/transform.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [errors](./src/errors/stream-error.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [stream-error](./src/errors/stream-error.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [factory](./src/factory/factory/factory.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [factory](./src/factory/factory/factory.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [transform](./src/instrument/transform/transform.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [transform](./src/instrument/transform/transform.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [manager](./src/manager/manager/manager.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [manager](./src/manager/manager/manager.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [node](./src/node/node-adapters.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [node-adapters](./src/node/node-adapters.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [builder](./src/pipeline/builder/builder.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [builder](./src/pipeline/builder/builder.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [concat](./src/pipeline/concat/concat.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [concat](./src/pipeline/concat/concat.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [fan-out](./src/pipeline/fan-out/fan-out.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [fan-out](./src/pipeline/fan-out/fan-out.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [merge](./src/pipeline/merge/merge.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [merge](./src/pipeline/merge/merge.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [merge-ordered](./src/pipeline/merge-ordered/merge-ordered.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [merge-ordered](./src/pipeline/merge-ordered/merge-ordered.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [partition](./src/pipeline/partition/partition.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [partition](./src/pipeline/partition/partition.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [route](./src/pipeline/route/route.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [route](./src/pipeline/route/route.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [safe-branch](./src/pipeline/safe-branch/safe-branch.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [safe-branch](./src/pipeline/safe-branch/safe-branch.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [zip](./src/pipeline/zip/zip.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [zip](./src/pipeline/zip/zip.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [duplex](./src/primitives/duplex/duplex.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [duplex](./src/primitives/duplex/duplex.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [network](./src/primitives/network/network.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [network](./src/primitives/network/network.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [from-array](./src/readable/from-array/from-array.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [from-array](./src/readable/from-array/from-array.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [from-bytes](./src/readable/from-bytes/from-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [from-bytes](./src/readable/from-bytes/from-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [from-generator](./src/readable/from-generator/from-generator.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [from-generator](./src/readable/from-generator/from-generator.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [for-each](./src/sinks/for-each/for-each.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [for-each](./src/sinks/for-each/for-each.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [to-array](./src/sinks/to-array/to-array.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [to-array](./src/sinks/to-array/to-array.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [to-async-iterable](./src/sinks/to-async-iterable/to-async-iterable.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [to-async-iterable](./src/sinks/to-async-iterable/to-async-iterable.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [to-bytes](./src/sinks/to-bytes/to-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [to-bytes](./src/sinks/to-bytes/to-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [batch](./src/transforms/batch/batch.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [batch](./src/transforms/batch/batch.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [chunk-bytes](./src/transforms/chunk-bytes/chunk-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [chunk-bytes](./src/transforms/chunk-bytes/chunk-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [coalesce-bytes](./src/transforms/coalesce-bytes/coalesce-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [coalesce-bytes](./src/transforms/coalesce-bytes/coalesce-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [compress](./src/transforms/compress/compress.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [compress](./src/transforms/compress/compress.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [crypto](./src/transforms/crypto/crypto.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [crypto](./src/transforms/crypto/crypto.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [dedup](./src/transforms/dedup/dedup.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [dedup](./src/transforms/dedup/dedup.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [filter](./src/transforms/filter/filter.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [filter](./src/transforms/filter/filter.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [flat-map](./src/transforms/flat-map/flat-map.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [flat-map](./src/transforms/flat-map/flat-map.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [length-prefix-decode](./src/transforms/length-prefix-decode/length-prefix-decode.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [length-prefix-decode](./src/transforms/length-prefix-decode/length-prefix-decode.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [length-prefix-encode](./src/transforms/length-prefix-encode/length-prefix-encode.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [length-prefix-encode](./src/transforms/length-prefix-encode/length-prefix-encode.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [limit](./src/transforms/limit/limit.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [limit](./src/transforms/limit/limit.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [map](./src/transforms/map/map.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [map](./src/transforms/map/map.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [sliding-bytes](./src/transforms/sliding-bytes/sliding-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [sliding-bytes](./src/transforms/sliding-bytes/sliding-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [split-join](./src/transforms/split-join/split-join.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [split-join](./src/transforms/split-join/split-join.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [tap](./src/transforms/tap/tap.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [tap](./src/transforms/tap/tap.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [text-codec](./src/transforms/text-codec/text-codec.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [text-codec](./src/transforms/text-codec/text-codec.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [throttle](./src/transforms/throttle/throttle.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [throttle](./src/transforms/throttle/throttle.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [window](./src/transforms/window/window.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [window](./src/transforms/window/window.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [types](./src/types/common.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [common](./src/types/common.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [buffer-to-uint8](./src/utils/buffer/buffer-to-uint8/buffer-to-uint8.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [buffer-to-uint8](./src/utils/buffer/buffer-to-uint8/buffer-to-uint8.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [get-data-from-file](./src/utils/buffer/get-data-from-file/get-data-from-file.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [get-data-from-file](./src/utils/buffer/get-data-from-file/get-data-from-file.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [uint8-slice](./src/utils/buffer/uint8-slice/uint8-slice.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [uint8-slice](./src/utils/buffer/uint8-slice/uint8-slice.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [create-data-stream](./src/utils/stream/create-data-stream/create-data-stream.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [create-data-stream](./src/utils/stream/create-data-stream/create-data-stream.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [process-data-stream](./src/utils/stream/process-data-stream/process-data-stream.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [process-data-stream](./src/utils/stream/process-data-stream/process-data-stream.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [round-trip](./src/utils/stream/round-trip/round-trip.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [round-trip](./src/utils/stream/round-trip/round-trip.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [validate-integrity](./src/utils/stream/validate-integrity/validate-integrity.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
- [validate-integrity](./src/utils/stream/validate-integrity/validate-integrity.md) — <!-- begin:auto-docs --> _(no submodules)_ <!-- end:auto-docs -->
|
|
<!-- end:auto-docs --> - [transform](./src/base/transform/transform.md) — <!-- begin:auto-docs --> _(no submodules)_- [errors](./src/errors/stream-error.md) — <!-- begin:auto-docs --> _(no submodules)_- [stream-error](./src/errors/stream-error.md) — <!-- begin:auto-docs --> _(no submodules)_- [factory](./src/factory/factory/factory.md) — <!-- begin:auto-docs --> _(no submodules)_- [factory](./src/factory/factory/factory.md) — <!-- begin:auto-docs --> _(no submodules)_- [transform](./src/instrument/transform/transform.md) — <!-- begin:auto-docs --> _(no submodules)_- [transform](./src/instrument/transform/transform.md) — <!-- begin:auto-docs --> _(no submodules)_- [manager](./src/manager/manager/manager.md) — <!-- begin:auto-docs --> _(no submodules)_- [manager](./src/manager/manager/manager.md) — <!-- begin:auto-docs --> _(no submodules)_- [node](./src/node/node-adapters.md) — <!-- begin:auto-docs --> _(no submodules)_- [node-adapters](./src/node/node-adapters.md) — <!-- begin:auto-docs --> _(no submodules)_- [builder](./src/pipeline/builder/builder.md) — <!-- begin:auto-docs --> _(no submodules)_- [builder](./src/pipeline/builder/builder.md) — <!-- begin:auto-docs --> _(no submodules)_- [concat](./src/pipeline/concat/concat.md) — <!-- begin:auto-docs --> _(no submodules)_- [concat](./src/pipeline/concat/concat.md) — <!-- begin:auto-docs --> _(no submodules)_- [fan-out](./src/pipeline/fan-out/fan-out.md) — <!-- begin:auto-docs --> _(no submodules)_- [fan-out](./src/pipeline/fan-out/fan-out.md) — <!-- begin:auto-docs --> _(no submodules)_- [merge](./src/pipeline/merge/merge.md) — <!-- begin:auto-docs --> _(no submodules)_- [merge](./src/pipeline/merge/merge.md) — <!-- begin:auto-docs --> _(no submodules)_- [merge-ordered](./src/pipeline/merge-ordered/merge-ordered.md) — <!-- begin:auto-docs --> _(no submodules)_- [merge-ordered](./src/pipeline/merge-ordered/merge-ordered.md) — <!-- begin:auto-docs --> _(no submodules)_- [partition](./src/pipeline/partition/partition.md) — <!-- begin:auto-docs --> _(no submodules)_- [partition](./src/pipeline/partition/partition.md) — <!-- begin:auto-docs --> _(no submodules)_- [route](./src/pipeline/route/route.md) — <!-- begin:auto-docs --> _(no submodules)_- [route](./src/pipeline/route/route.md) — <!-- begin:auto-docs --> _(no submodules)_- [safe-branch](./src/pipeline/safe-branch/safe-branch.md) — <!-- begin:auto-docs --> _(no submodules)_- [safe-branch](./src/pipeline/safe-branch/safe-branch.md) — <!-- begin:auto-docs --> _(no submodules)_- [zip](./src/pipeline/zip/zip.md) — <!-- begin:auto-docs --> _(no submodules)_- [zip](./src/pipeline/zip/zip.md) — <!-- begin:auto-docs --> _(no submodules)_- [duplex](./src/primitives/duplex/duplex.md) — <!-- begin:auto-docs --> _(no submodules)_- [duplex](./src/primitives/duplex/duplex.md) — <!-- begin:auto-docs --> _(no submodules)_- [network](./src/primitives/network/network.md) — <!-- begin:auto-docs --> _(no submodules)_- [network](./src/primitives/network/network.md) — <!-- begin:auto-docs --> _(no submodules)_- [from-array](./src/readable/from-array/from-array.md) — <!-- begin:auto-docs --> _(no submodules)_- [from-array](./src/readable/from-array/from-array.md) — <!-- begin:auto-docs --> _(no submodules)_- [from-bytes](./src/readable/from-bytes/from-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [from-bytes](./src/readable/from-bytes/from-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [from-generator](./src/readable/from-generator/from-generator.md) — <!-- begin:auto-docs --> _(no submodules)_- [from-generator](./src/readable/from-generator/from-generator.md) — <!-- begin:auto-docs --> _(no submodules)_- [for-each](./src/sinks/for-each/for-each.md) — <!-- begin:auto-docs --> _(no submodules)_- [for-each](./src/sinks/for-each/for-each.md) — <!-- begin:auto-docs --> _(no submodules)_- [to-array](./src/sinks/to-array/to-array.md) — <!-- begin:auto-docs --> _(no submodules)_- [to-array](./src/sinks/to-array/to-array.md) — <!-- begin:auto-docs --> _(no submodules)_- [to-async-iterable](./src/sinks/to-async-iterable/to-async-iterable.md) — <!-- begin:auto-docs --> _(no submodules)_- [to-async-iterable](./src/sinks/to-async-iterable/to-async-iterable.md) — <!-- begin:auto-docs --> _(no submodules)_- [to-bytes](./src/sinks/to-bytes/to-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [to-bytes](./src/sinks/to-bytes/to-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [batch](./src/transforms/batch/batch.md) — <!-- begin:auto-docs --> _(no submodules)_- [batch](./src/transforms/batch/batch.md) — <!-- begin:auto-docs --> _(no submodules)_- [chunk-bytes](./src/transforms/chunk-bytes/chunk-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [chunk-bytes](./src/transforms/chunk-bytes/chunk-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [coalesce-bytes](./src/transforms/coalesce-bytes/coalesce-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [coalesce-bytes](./src/transforms/coalesce-bytes/coalesce-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [compress](./src/transforms/compress/compress.md) — <!-- begin:auto-docs --> _(no submodules)_- [compress](./src/transforms/compress/compress.md) — <!-- begin:auto-docs --> _(no submodules)_- [crypto](./src/transforms/crypto/crypto.md) — <!-- begin:auto-docs --> _(no submodules)_- [crypto](./src/transforms/crypto/crypto.md) — <!-- begin:auto-docs --> _(no submodules)_- [dedup](./src/transforms/dedup/dedup.md) — <!-- begin:auto-docs --> _(no submodules)_- [dedup](./src/transforms/dedup/dedup.md) — <!-- begin:auto-docs --> _(no submodules)_- [filter](./src/transforms/filter/filter.md) — <!-- begin:auto-docs --> _(no submodules)_- [filter](./src/transforms/filter/filter.md) — <!-- begin:auto-docs --> _(no submodules)_- [flat-map](./src/transforms/flat-map/flat-map.md) — <!-- begin:auto-docs --> _(no submodules)_- [flat-map](./src/transforms/flat-map/flat-map.md) — <!-- begin:auto-docs --> _(no submodules)_- [length-prefix-decode](./src/transforms/length-prefix-decode/length-prefix-decode.md) — <!-- begin:auto-docs --> _(no submodules)_- [length-prefix-decode](./src/transforms/length-prefix-decode/length-prefix-decode.md) — <!-- begin:auto-docs --> _(no submodules)_- [length-prefix-encode](./src/transforms/length-prefix-encode/length-prefix-encode.md) — <!-- begin:auto-docs --> _(no submodules)_- [length-prefix-encode](./src/transforms/length-prefix-encode/length-prefix-encode.md) — <!-- begin:auto-docs --> _(no submodules)_- [limit](./src/transforms/limit/limit.md) — <!-- begin:auto-docs --> _(no submodules)_- [limit](./src/transforms/limit/limit.md) — <!-- begin:auto-docs --> _(no submodules)_- [map](./src/transforms/map/map.md) — <!-- begin:auto-docs --> _(no submodules)_- [map](./src/transforms/map/map.md) — <!-- begin:auto-docs --> _(no submodules)_- [sliding-bytes](./src/transforms/sliding-bytes/sliding-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [sliding-bytes](./src/transforms/sliding-bytes/sliding-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [split-join](./src/transforms/split-join/split-join.md) — <!-- begin:auto-docs --> _(no submodules)_- [split-join](./src/transforms/split-join/split-join.md) — <!-- begin:auto-docs --> _(no submodules)_- [tap](./src/transforms/tap/tap.md) — <!-- begin:auto-docs --> _(no submodules)_- [tap](./src/transforms/tap/tap.md) — <!-- begin:auto-docs --> _(no submodules)_- [text-codec](./src/transforms/text-codec/text-codec.md) — <!-- begin:auto-docs --> _(no submodules)_- [text-codec](./src/transforms/text-codec/text-codec.md) — <!-- begin:auto-docs --> _(no submodules)_- [throttle](./src/transforms/throttle/throttle.md) — <!-- begin:auto-docs --> _(no submodules)_- [throttle](./src/transforms/throttle/throttle.md) — <!-- begin:auto-docs --> _(no submodules)_- [window](./src/transforms/window/window.md) — <!-- begin:auto-docs --> _(no submodules)_- [window](./src/transforms/window/window.md) — <!-- begin:auto-docs --> _(no submodules)_- [types](./src/types/common.md) — <!-- begin:auto-docs --> _(no submodules)_- [common](./src/types/common.md) — <!-- begin:auto-docs --> _(no submodules)_- [buffer-to-uint8](./src/utils/buffer/buffer-to-uint8/buffer-to-uint8.md) — <!-- begin:auto-docs --> _(no submodules)_- [buffer-to-uint8](./src/utils/buffer/buffer-to-uint8/buffer-to-uint8.md) — <!-- begin:auto-docs --> _(no submodules)_- [get-data-from-file](./src/utils/buffer/get-data-from-file/get-data-from-file.md) — <!-- begin:auto-docs --> _(no submodules)_- [get-data-from-file](./src/utils/buffer/get-data-from-file/get-data-from-file.md) — <!-- begin:auto-docs --> _(no submodules)_- [uint8-slice](./src/utils/buffer/uint8-slice/uint8-slice.md) — <!-- begin:auto-docs --> _(no submodules)_- [uint8-slice](./src/utils/buffer/uint8-slice/uint8-slice.md) — <!-- begin:auto-docs --> _(no submodules)_- [create-data-stream](./src/utils/stream/create-data-stream/create-data-stream.md) — <!-- begin:auto-docs --> _(no submodules)_- [create-data-stream](./src/utils/stream/create-data-stream/create-data-stream.md) — <!-- begin:auto-docs --> _(no submodules)_- [process-data-stream](./src/utils/stream/process-data-stream/process-data-stream.md) — <!-- begin:auto-docs --> _(no submodules)_- [process-data-stream](./src/utils/stream/process-data-stream/process-data-stream.md) — <!-- begin:auto-docs --> _(no submodules)_- [round-trip](./src/utils/stream/round-trip/round-trip.md) — <!-- begin:auto-docs --> _(no submodules)_- [round-trip](./src/utils/stream/round-trip/round-trip.md) — <!-- begin:auto-docs --> _(no submodules)_- [validate-integrity](./src/utils/stream/validate-integrity/validate-integrity.md) — <!-- begin:auto-docs --> _(no submodules)_- [validate-integrity](./src/utils/stream/validate-integrity/validate-integrity.md) — <!-- begin:auto-docs --> _(no submodules)_- [transform](./src/base/transform/transform.md) — <!-- begin:auto-docs --> _(no submodules)_- [errors](./src/errors/stream-error.md) — <!-- begin:auto-docs --> _(no submodules)_- [stream-error](./src/errors/stream-error.md) — <!-- begin:auto-docs --> _(no submodules)_- [factory](./src/factory/factory/factory.md) — <!-- begin:auto-docs --> _(no submodules)_- [factory](./src/factory/factory/factory.md) — <!-- begin:auto-docs --> _(no submodules)_- [transform](./src/instrument/transform/transform.md) — <!-- begin:auto-docs --> _(no submodules)_- [transform](./src/instrument/transform/transform.md) — <!-- begin:auto-docs --> _(no submodules)_- [manager](./src/manager/manager/manager.md) — <!-- begin:auto-docs --> _(no submodules)_- [manager](./src/manager/manager/manager.md) — <!-- begin:auto-docs --> _(no submodules)_- [node](./src/node/node-adapters.md) — <!-- begin:auto-docs --> _(no submodules)_- [node-adapters](./src/node/node-adapters.md) — <!-- begin:auto-docs --> _(no submodules)_- [builder](./src/pipeline/builder/builder.md) — <!-- begin:auto-docs --> _(no submodules)_- [builder](./src/pipeline/builder/builder.md) — <!-- begin:auto-docs --> _(no submodules)_- [concat](./src/pipeline/concat/concat.md) — <!-- begin:auto-docs --> _(no submodules)_- [concat](./src/pipeline/concat/concat.md) — <!-- begin:auto-docs --> _(no submodules)_- [fan-out](./src/pipeline/fan-out/fan-out.md) — <!-- begin:auto-docs --> _(no submodules)_- [fan-out](./src/pipeline/fan-out/fan-out.md) — <!-- begin:auto-docs --> _(no submodules)_- [merge](./src/pipeline/merge/merge.md) — <!-- begin:auto-docs --> _(no submodules)_- [merge](./src/pipeline/merge/merge.md) — <!-- begin:auto-docs --> _(no submodules)_- [merge-ordered](./src/pipeline/merge-ordered/merge-ordered.md) — <!-- begin:auto-docs --> _(no submodules)_- [merge-ordered](./src/pipeline/merge-ordered/merge-ordered.md) — <!-- begin:auto-docs --> _(no submodules)_- [partition](./src/pipeline/partition/partition.md) — <!-- begin:auto-docs --> _(no submodules)_- [partition](./src/pipeline/partition/partition.md) — <!-- begin:auto-docs --> _(no submodules)_- [route](./src/pipeline/route/route.md) — <!-- begin:auto-docs --> _(no submodules)_- [route](./src/pipeline/route/route.md) — <!-- begin:auto-docs --> _(no submodules)_- [safe-branch](./src/pipeline/safe-branch/safe-branch.md) — <!-- begin:auto-docs --> _(no submodules)_- [safe-branch](./src/pipeline/safe-branch/safe-branch.md) — <!-- begin:auto-docs --> _(no submodules)_- [zip](./src/pipeline/zip/zip.md) — <!-- begin:auto-docs --> _(no submodules)_- [zip](./src/pipeline/zip/zip.md) — <!-- begin:auto-docs --> _(no submodules)_- [duplex](./src/primitives/duplex/duplex.md) — <!-- begin:auto-docs --> _(no submodules)_- [duplex](./src/primitives/duplex/duplex.md) — <!-- begin:auto-docs --> _(no submodules)_- [network](./src/primitives/network/network.md) — <!-- begin:auto-docs --> _(no submodules)_- [network](./src/primitives/network/network.md) — <!-- begin:auto-docs --> _(no submodules)_- [from-array](./src/readable/from-array/from-array.md) — <!-- begin:auto-docs --> _(no submodules)_- [from-array](./src/readable/from-array/from-array.md) — <!-- begin:auto-docs --> _(no submodules)_- [from-bytes](./src/readable/from-bytes/from-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [from-bytes](./src/readable/from-bytes/from-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [from-generator](./src/readable/from-generator/from-generator.md) — <!-- begin:auto-docs --> _(no submodules)_- [from-generator](./src/readable/from-generator/from-generator.md) — <!-- begin:auto-docs --> _(no submodules)_- [for-each](./src/sinks/for-each/for-each.md) — <!-- begin:auto-docs --> _(no submodules)_- [for-each](./src/sinks/for-each/for-each.md) — <!-- begin:auto-docs --> _(no submodules)_- [to-array](./src/sinks/to-array/to-array.md) — <!-- begin:auto-docs --> _(no submodules)_- [to-array](./src/sinks/to-array/to-array.md) — <!-- begin:auto-docs --> _(no submodules)_- [to-async-iterable](./src/sinks/to-async-iterable/to-async-iterable.md) — <!-- begin:auto-docs --> _(no submodules)_- [to-async-iterable](./src/sinks/to-async-iterable/to-async-iterable.md) — <!-- begin:auto-docs --> _(no submodules)_- [to-bytes](./src/sinks/to-bytes/to-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [to-bytes](./src/sinks/to-bytes/to-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [batch](./src/transforms/batch/batch.md) — <!-- begin:auto-docs --> _(no submodules)_- [batch](./src/transforms/batch/batch.md) — <!-- begin:auto-docs --> _(no submodules)_- [chunk-bytes](./src/transforms/chunk-bytes/chunk-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [chunk-bytes](./src/transforms/chunk-bytes/chunk-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [coalesce-bytes](./src/transforms/coalesce-bytes/coalesce-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [coalesce-bytes](./src/transforms/coalesce-bytes/coalesce-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [compress](./src/transforms/compress/compress.md) — <!-- begin:auto-docs --> _(no submodules)_- [compress](./src/transforms/compress/compress.md) — <!-- begin:auto-docs --> _(no submodules)_- [crypto](./src/transforms/crypto/crypto.md) — <!-- begin:auto-docs --> _(no submodules)_- [crypto](./src/transforms/crypto/crypto.md) — <!-- begin:auto-docs --> _(no submodules)_- [dedup](./src/transforms/dedup/dedup.md) — <!-- begin:auto-docs --> _(no submodules)_- [dedup](./src/transforms/dedup/dedup.md) — <!-- begin:auto-docs --> _(no submodules)_- [filter](./src/transforms/filter/filter.md) — <!-- begin:auto-docs --> _(no submodules)_- [filter](./src/transforms/filter/filter.md) — <!-- begin:auto-docs --> _(no submodules)_- [flat-map](./src/transforms/flat-map/flat-map.md) — <!-- begin:auto-docs --> _(no submodules)_- [flat-map](./src/transforms/flat-map/flat-map.md) — <!-- begin:auto-docs --> _(no submodules)_- [length-prefix-decode](./src/transforms/length-prefix-decode/length-prefix-decode.md) — <!-- begin:auto-docs --> _(no submodules)_- [length-prefix-decode](./src/transforms/length-prefix-decode/length-prefix-decode.md) — <!-- begin:auto-docs --> _(no submodules)_- [length-prefix-encode](./src/transforms/length-prefix-encode/length-prefix-encode.md) — <!-- begin:auto-docs --> _(no submodules)_- [length-prefix-encode](./src/transforms/length-prefix-encode/length-prefix-encode.md) — <!-- begin:auto-docs --> _(no submodules)_- [limit](./src/transforms/limit/limit.md) — <!-- begin:auto-docs --> _(no submodules)_- [limit](./src/transforms/limit/limit.md) — <!-- begin:auto-docs --> _(no submodules)_- [map](./src/transforms/map/map.md) — <!-- begin:auto-docs --> _(no submodules)_- [map](./src/transforms/map/map.md) — <!-- begin:auto-docs --> _(no submodules)_- [sliding-bytes](./src/transforms/sliding-bytes/sliding-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [sliding-bytes](./src/transforms/sliding-bytes/sliding-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [split-join](./src/transforms/split-join/split-join.md) — <!-- begin:auto-docs --> _(no submodules)_- [split-join](./src/transforms/split-join/split-join.md) — <!-- begin:auto-docs --> _(no submodules)_- [tap](./src/transforms/tap/tap.md) — <!-- begin:auto-docs --> _(no submodules)_- [tap](./src/transforms/tap/tap.md) — <!-- begin:auto-docs --> _(no submodules)_- [text-codec](./src/transforms/text-codec/text-codec.md) — <!-- begin:auto-docs --> _(no submodules)_- [text-codec](./src/transforms/text-codec/text-codec.md) — <!-- begin:auto-docs --> _(no submodules)_- [throttle](./src/transforms/throttle/throttle.md) — <!-- begin:auto-docs --> _(no submodules)_- [throttle](./src/transforms/throttle/throttle.md) — <!-- begin:auto-docs --> _(no submodules)_- [window](./src/transforms/window/window.md) — <!-- begin:auto-docs --> _(no submodules)_- [window](./src/transforms/window/window.md) — <!-- begin:auto-docs --> _(no submodules)_- [types](./src/types/common.md) — <!-- begin:auto-docs --> _(no submodules)_- [common](./src/types/common.md) — <!-- begin:auto-docs --> _(no submodules)_- [buffer-to-uint8](./src/utils/buffer/buffer-to-uint8/buffer-to-uint8.md) — <!-- begin:auto-docs --> _(no submodules)_- [buffer-to-uint8](./src/utils/buffer/buffer-to-uint8/buffer-to-uint8.md) — <!-- begin:auto-docs --> _(no submodules)_- [get-data-from-file](./src/utils/buffer/get-data-from-file/get-data-from-file.md) — <!-- begin:auto-docs --> _(no submodules)_- [get-data-from-file](./src/utils/buffer/get-data-from-file/get-data-from-file.md) — <!-- begin:auto-docs --> _(no submodules)_- [uint8-slice](./src/utils/buffer/uint8-slice/uint8-slice.md) — <!-- begin:auto-docs --> _(no submodules)_- [uint8-slice](./src/utils/buffer/uint8-slice/uint8-slice.md) — <!-- begin:auto-docs --> _(no submodules)_- [create-data-stream](./src/utils/stream/create-data-stream/create-data-stream.md) — <!-- begin:auto-docs --> _(no submodules)_- [create-data-stream](./src/utils/stream/create-data-stream/create-data-stream.md) — <!-- begin:auto-docs --> _(no submodules)_- [process-data-stream](./src/utils/stream/process-data-stream/process-data-stream.md) — <!-- begin:auto-docs --> _(no submodules)_- [process-data-stream](./src/utils/stream/process-data-stream/process-data-stream.md) — <!-- begin:auto-docs --> _(no submodules)_- [round-trip](./src/utils/stream/round-trip/round-trip.md) — <!-- begin:auto-docs --> _(no submodules)_- [round-trip](./src/utils/stream/round-trip/round-trip.md) — <!-- begin:auto-docs --> _(no submodules)_- [validate-integrity](./src/utils/stream/validate-integrity/validate-integrity.md) — <!-- begin:auto-docs --> _(no submodules)_- [validate-integrity](./src/utils/stream/validate-integrity/validate-integrity.md) — <!-- begin:auto-docs --> _(no submodules)_- [transform](./src/base/transform/transform.md) — <!-- begin:auto-docs --> _(no submodules)_- [errors](./src/errors/stream-error.md) — <!-- begin:auto-docs --> _(no submodules)_- [stream-error](./src/errors/stream-error.md) — <!-- begin:auto-docs --> _(no submodules)_- [factory](./src/factory/factory/factory.md) — <!-- begin:auto-docs --> _(no submodules)_- [factory](./src/factory/factory/factory.md) — <!-- begin:auto-docs --> _(no submodules)_- [transform](./src/instrument/transform/transform.md) — <!-- begin:auto-docs --> _(no submodules)_- [transform](./src/instrument/transform/transform.md) — <!-- begin:auto-docs --> _(no submodules)_- [manager](./src/manager/manager/manager.md) — <!-- begin:auto-docs --> _(no submodules)_- [manager](./src/manager/manager/manager.md) — <!-- begin:auto-docs --> _(no submodules)_- [node](./src/node/node-adapters.md) — <!-- begin:auto-docs --> _(no submodules)_- [node-adapters](./src/node/node-adapters.md) — <!-- begin:auto-docs --> _(no submodules)_- [builder](./src/pipeline/builder/builder.md) — <!-- begin:auto-docs --> _(no submodules)_- [builder](./src/pipeline/builder/builder.md) — <!-- begin:auto-docs --> _(no submodules)_- [concat](./src/pipeline/concat/concat.md) — <!-- begin:auto-docs --> _(no submodules)_- [concat](./src/pipeline/concat/concat.md) — <!-- begin:auto-docs --> _(no submodules)_- [fan-out](./src/pipeline/fan-out/fan-out.md) — <!-- begin:auto-docs --> _(no submodules)_- [fan-out](./src/pipeline/fan-out/fan-out.md) — <!-- begin:auto-docs --> _(no submodules)_- [merge](./src/pipeline/merge/merge.md) — <!-- begin:auto-docs --> _(no submodules)_- [merge](./src/pipeline/merge/merge.md) — <!-- begin:auto-docs --> _(no submodules)_- [merge-ordered](./src/pipeline/merge-ordered/merge-ordered.md) — <!-- begin:auto-docs --> _(no submodules)_- [merge-ordered](./src/pipeline/merge-ordered/merge-ordered.md) — <!-- begin:auto-docs --> _(no submodules)_- [partition](./src/pipeline/partition/partition.md) — <!-- begin:auto-docs --> _(no submodules)_- [partition](./src/pipeline/partition/partition.md) — <!-- begin:auto-docs --> _(no submodules)_- [route](./src/pipeline/route/route.md) — <!-- begin:auto-docs --> _(no submodules)_- [route](./src/pipeline/route/route.md) — <!-- begin:auto-docs --> _(no submodules)_- [safe-branch](./src/pipeline/safe-branch/safe-branch.md) — <!-- begin:auto-docs --> _(no submodules)_- [safe-branch](./src/pipeline/safe-branch/safe-branch.md) — <!-- begin:auto-docs --> _(no submodules)_- [zip](./src/pipeline/zip/zip.md) — <!-- begin:auto-docs --> _(no submodules)_- [zip](./src/pipeline/zip/zip.md) — <!-- begin:auto-docs --> _(no submodules)_- [duplex](./src/primitives/duplex/duplex.md) — <!-- begin:auto-docs --> _(no submodules)_- [duplex](./src/primitives/duplex/duplex.md) — <!-- begin:auto-docs --> _(no submodules)_- [network](./src/primitives/network/network.md) — <!-- begin:auto-docs --> _(no submodules)_- [network](./src/primitives/network/network.md) — <!-- begin:auto-docs --> _(no submodules)_- [from-array](./src/readable/from-array/from-array.md) — <!-- begin:auto-docs --> _(no submodules)_- [from-array](./src/readable/from-array/from-array.md) — <!-- begin:auto-docs --> _(no submodules)_- [from-bytes](./src/readable/from-bytes/from-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [from-bytes](./src/readable/from-bytes/from-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [from-generator](./src/readable/from-generator/from-generator.md) — <!-- begin:auto-docs --> _(no submodules)_- [from-generator](./src/readable/from-generator/from-generator.md) — <!-- begin:auto-docs --> _(no submodules)_- [for-each](./src/sinks/for-each/for-each.md) — <!-- begin:auto-docs --> _(no submodules)_- [for-each](./src/sinks/for-each/for-each.md) — <!-- begin:auto-docs --> _(no submodules)_- [to-array](./src/sinks/to-array/to-array.md) — <!-- begin:auto-docs --> _(no submodules)_- [to-array](./src/sinks/to-array/to-array.md) — <!-- begin:auto-docs --> _(no submodules)_- [to-async-iterable](./src/sinks/to-async-iterable/to-async-iterable.md) — <!-- begin:auto-docs --> _(no submodules)_- [to-async-iterable](./src/sinks/to-async-iterable/to-async-iterable.md) — <!-- begin:auto-docs --> _(no submodules)_- [to-bytes](./src/sinks/to-bytes/to-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [to-bytes](./src/sinks/to-bytes/to-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [batch](./src/transforms/batch/batch.md) — <!-- begin:auto-docs --> _(no submodules)_- [batch](./src/transforms/batch/batch.md) — <!-- begin:auto-docs --> _(no submodules)_- [chunk-bytes](./src/transforms/chunk-bytes/chunk-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [chunk-bytes](./src/transforms/chunk-bytes/chunk-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [coalesce-bytes](./src/transforms/coalesce-bytes/coalesce-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [coalesce-bytes](./src/transforms/coalesce-bytes/coalesce-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [compress](./src/transforms/compress/compress.md) — <!-- begin:auto-docs --> _(no submodules)_- [compress](./src/transforms/compress/compress.md) — <!-- begin:auto-docs --> _(no submodules)_- [crypto](./src/transforms/crypto/crypto.md) — <!-- begin:auto-docs --> _(no submodules)_- [crypto](./src/transforms/crypto/crypto.md) — <!-- begin:auto-docs --> _(no submodules)_- [dedup](./src/transforms/dedup/dedup.md) — <!-- begin:auto-docs --> _(no submodules)_- [dedup](./src/transforms/dedup/dedup.md) — <!-- begin:auto-docs --> _(no submodules)_- [filter](./src/transforms/filter/filter.md) — <!-- begin:auto-docs --> _(no submodules)_- [filter](./src/transforms/filter/filter.md) — <!-- begin:auto-docs --> _(no submodules)_- [flat-map](./src/transforms/flat-map/flat-map.md) — <!-- begin:auto-docs --> _(no submodules)_- [flat-map](./src/transforms/flat-map/flat-map.md) — <!-- begin:auto-docs --> _(no submodules)_- [length-prefix-decode](./src/transforms/length-prefix-decode/length-prefix-decode.md) — <!-- begin:auto-docs --> _(no submodules)_- [length-prefix-decode](./src/transforms/length-prefix-decode/length-prefix-decode.md) — <!-- begin:auto-docs --> _(no submodules)_- [length-prefix-encode](./src/transforms/length-prefix-encode/length-prefix-encode.md) — <!-- begin:auto-docs --> _(no submodules)_- [length-prefix-encode](./src/transforms/length-prefix-encode/length-prefix-encode.md) — <!-- begin:auto-docs --> _(no submodules)_- [limit](./src/transforms/limit/limit.md) — <!-- begin:auto-docs --> _(no submodules)_- [limit](./src/transforms/limit/limit.md) — <!-- begin:auto-docs --> _(no submodules)_- [map](./src/transforms/map/map.md) — <!-- begin:auto-docs --> _(no submodules)_- [map](./src/transforms/map/map.md) — <!-- begin:auto-docs --> _(no submodules)_- [sliding-bytes](./src/transforms/sliding-bytes/sliding-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [sliding-bytes](./src/transforms/sliding-bytes/sliding-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [split-join](./src/transforms/split-join/split-join.md) — <!-- begin:auto-docs --> _(no submodules)_- [split-join](./src/transforms/split-join/split-join.md) — <!-- begin:auto-docs --> _(no submodules)_- [tap](./src/transforms/tap/tap.md) — <!-- begin:auto-docs --> _(no submodules)_- [tap](./src/transforms/tap/tap.md) — <!-- begin:auto-docs --> _(no submodules)_- [text-codec](./src/transforms/text-codec/text-codec.md) — <!-- begin:auto-docs --> _(no submodules)_- [text-codec](./src/transforms/text-codec/text-codec.md) — <!-- begin:auto-docs --> _(no submodules)_- [throttle](./src/transforms/throttle/throttle.md) — <!-- begin:auto-docs --> _(no submodules)_- [throttle](./src/transforms/throttle/throttle.md) — <!-- begin:auto-docs --> _(no submodules)_- [window](./src/transforms/window/window.md) — <!-- begin:auto-docs --> _(no submodules)_- [window](./src/transforms/window/window.md) — <!-- begin:auto-docs --> _(no submodules)_- [types](./src/types/common.md) — <!-- begin:auto-docs --> _(no submodules)_- [common](./src/types/common.md) — <!-- begin:auto-docs --> _(no submodules)_- [buffer-to-uint8](./src/utils/buffer/buffer-to-uint8/buffer-to-uint8.md) — <!-- begin:auto-docs --> _(no submodules)_- [buffer-to-uint8](./src/utils/buffer/buffer-to-uint8/buffer-to-uint8.md) — <!-- begin:auto-docs --> _(no submodules)_- [get-data-from-file](./src/utils/buffer/get-data-from-file/get-data-from-file.md) — <!-- begin:auto-docs --> _(no submodules)_- [get-data-from-file](./src/utils/buffer/get-data-from-file/get-data-from-file.md) — <!-- begin:auto-docs --> _(no submodules)_- [uint8-slice](./src/utils/buffer/uint8-slice/uint8-slice.md) — <!-- begin:auto-docs --> _(no submodules)_- [uint8-slice](./src/utils/buffer/uint8-slice/uint8-slice.md) — <!-- begin:auto-docs --> _(no submodules)_- [create-data-stream](./src/utils/stream/create-data-stream/create-data-stream.md) — <!-- begin:auto-docs --> _(no submodules)_- [create-data-stream](./src/utils/stream/create-data-stream/create-data-stream.md) — <!-- begin:auto-docs --> _(no submodules)_- [process-data-stream](./src/utils/stream/process-data-stream/process-data-stream.md) — <!-- begin:auto-docs --> _(no submodules)_- [process-data-stream](./src/utils/stream/process-data-stream/process-data-stream.md) — <!-- begin:auto-docs --> _(no submodules)_- [round-trip](./src/utils/stream/round-trip/round-trip.md) — <!-- begin:auto-docs --> _(no submodules)_- [round-trip](./src/utils/stream/round-trip/round-trip.md) — <!-- begin:auto-docs --> _(no submodules)_- [validate-integrity](./src/utils/stream/validate-integrity/validate-integrity.md) — <!-- begin:auto-docs --> _(no submodules)_- [validate-integrity](./src/utils/stream/validate-integrity/validate-integrity.md) — <!-- begin:auto-docs --> _(no submodules)_- [transform](./src/base/transform/transform.md) — <!-- begin:auto-docs --> _(no submodules)_- [errors](./src/errors/stream-error.md) — <!-- begin:auto-docs --> _(no submodules)_ - [stream-error](./src/errors/stream-error.md) — <!-- begin:auto-docs --> _(no submodules)_- [factory](./src/factory/factory/factory.md) — <!-- begin:auto-docs --> _(no submodules)_ - [factory](./src/factory/factory/factory.md) — <!-- begin:auto-docs --> _(no submodules)_- [transform](./src/instrument/transform/transform.md) — <!-- begin:auto-docs --> _(no submodules)_ - [transform](./src/instrument/transform/transform.md) — <!-- begin:auto-docs --> _(no submodules)_- [manager](./src/manager/manager/manager.md) — <!-- begin:auto-docs --> _(no submodules)_ - [manager](./src/manager/manager/manager.md) — <!-- begin:auto-docs --> _(no submodules)_- [node](./src/node/node-adapters.md) — <!-- begin:auto-docs --> _(no submodules)_ - [node-adapters](./src/node/node-adapters.md) — <!-- begin:auto-docs --> _(no submodules)_- [builder](./src/pipeline/builder/builder.md) — <!-- begin:auto-docs --> _(no submodules)_ - [builder](./src/pipeline/builder/builder.md) — <!-- begin:auto-docs --> _(no submodules)_- [concat](./src/pipeline/concat/concat.md) — <!-- begin:auto-docs --> _(no submodules)_ - [concat](./src/pipeline/concat/concat.md) — <!-- begin:auto-docs --> _(no submodules)_- [fan-out](./src/pipeline/fan-out/fan-out.md) — <!-- begin:auto-docs --> _(no submodules)_ - [fan-out](./src/pipeline/fan-out/fan-out.md) — <!-- begin:auto-docs --> _(no submodules)_- [merge](./src/pipeline/merge/merge.md) — <!-- begin:auto-docs --> _(no submodules)_ - [merge](./src/pipeline/merge/merge.md) — <!-- begin:auto-docs --> _(no submodules)_- [merge-ordered](./src/pipeline/merge-ordered/merge-ordered.md) — <!-- begin:auto-docs --> _(no submodules)_ - [merge-ordered](./src/pipeline/merge-ordered/merge-ordered.md) — <!-- begin:auto-docs --> _(no submodules)_- [partition](./src/pipeline/partition/partition.md) — <!-- begin:auto-docs --> _(no submodules)_ - [partition](./src/pipeline/partition/partition.md) — <!-- begin:auto-docs --> _(no submodules)_- [route](./src/pipeline/route/route.md) — <!-- begin:auto-docs --> _(no submodules)_ - [route](./src/pipeline/route/route.md) — <!-- begin:auto-docs --> _(no submodules)_- [safe-branch](./src/pipeline/safe-branch/safe-branch.md) — <!-- begin:auto-docs --> _(no submodules)_ - [safe-branch](./src/pipeline/safe-branch/safe-branch.md) — <!-- begin:auto-docs --> _(no submodules)_- [zip](./src/pipeline/zip/zip.md) — <!-- begin:auto-docs --> _(no submodules)_ - [zip](./src/pipeline/zip/zip.md) — <!-- begin:auto-docs --> _(no submodules)_- [duplex](./src/primitives/duplex/duplex.md) — <!-- begin:auto-docs --> _(no submodules)_ - [duplex](./src/primitives/duplex/duplex.md) — <!-- begin:auto-docs --> _(no submodules)_- [network](./src/primitives/network/network.md) — <!-- begin:auto-docs --> _(no submodules)_ - [network](./src/primitives/network/network.md) — <!-- begin:auto-docs --> _(no submodules)_- [from-array](./src/readable/from-array/from-array.md) — <!-- begin:auto-docs --> _(no submodules)_ - [from-array](./src/readable/from-array/from-array.md) — <!-- begin:auto-docs --> _(no submodules)_- [from-bytes](./src/readable/from-bytes/from-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_ - [from-bytes](./src/readable/from-bytes/from-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [from-generator](./src/readable/from-generator/from-generator.md) — <!-- begin:auto-docs --> _(no submodules)_ - [from-generator](./src/readable/from-generator/from-generator.md) — <!-- begin:auto-docs --> _(no submodules)_- [for-each](./src/sinks/for-each/for-each.md) — <!-- begin:auto-docs --> _(no submodules)_ - [for-each](./src/sinks/for-each/for-each.md) — <!-- begin:auto-docs --> _(no submodules)_- [to-array](./src/sinks/to-array/to-array.md) — <!-- begin:auto-docs --> _(no submodules)_ - [to-array](./src/sinks/to-array/to-array.md) — <!-- begin:auto-docs --> _(no submodules)_- [to-async-iterable](./src/sinks/to-async-iterable/to-async-iterable.md) — <!-- begin:auto-docs --> _(no submodules)_ - [to-async-iterable](./src/sinks/to-async-iterable/to-async-iterable.md) — <!-- begin:auto-docs --> _(no submodules)_- [to-bytes](./src/sinks/to-bytes/to-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_ - [to-bytes](./src/sinks/to-bytes/to-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [batch](./src/transforms/batch/batch.md) — <!-- begin:auto-docs --> _(no submodules)_ - [batch](./src/transforms/batch/batch.md) — <!-- begin:auto-docs --> _(no submodules)_- [chunk-bytes](./src/transforms/chunk-bytes/chunk-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_ - [chunk-bytes](./src/transforms/chunk-bytes/chunk-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [coalesce-bytes](./src/transforms/coalesce-bytes/coalesce-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_ - [coalesce-bytes](./src/transforms/coalesce-bytes/coalesce-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [compress](./src/transforms/compress/compress.md) — <!-- begin:auto-docs --> _(no submodules)_ - [compress](./src/transforms/compress/compress.md) — <!-- begin:auto-docs --> _(no submodules)_- [crypto](./src/transforms/crypto/crypto.md) — <!-- begin:auto-docs --> _(no submodules)_ - [crypto](./src/transforms/crypto/crypto.md) — <!-- begin:auto-docs --> _(no submodules)_- [dedup](./src/transforms/dedup/dedup.md) — <!-- begin:auto-docs --> _(no submodules)_ - [dedup](./src/transforms/dedup/dedup.md) — <!-- begin:auto-docs --> _(no submodules)_- [filter](./src/transforms/filter/filter.md) — <!-- begin:auto-docs --> _(no submodules)_ - [filter](./src/transforms/filter/filter.md) — <!-- begin:auto-docs --> _(no submodules)_- [flat-map](./src/transforms/flat-map/flat-map.md) — <!-- begin:auto-docs --> _(no submodules)_ - [flat-map](./src/transforms/flat-map/flat-map.md) — <!-- begin:auto-docs --> _(no submodules)_- [length-prefix-decode](./src/transforms/length-prefix-decode/length-prefix-decode.md) — <!-- begin:auto-docs --> _(no submodules)_ - [length-prefix-decode](./src/transforms/length-prefix-decode/length-prefix-decode.md) — <!-- begin:auto-docs --> _(no submodules)_- [length-prefix-encode](./src/transforms/length-prefix-encode/length-prefix-encode.md) — <!-- begin:auto-docs --> _(no submodules)_ - [length-prefix-encode](./src/transforms/length-prefix-encode/length-prefix-encode.md) — <!-- begin:auto-docs --> _(no submodules)_- [limit](./src/transforms/limit/limit.md) — <!-- begin:auto-docs --> _(no submodules)_ - [limit](./src/transforms/limit/limit.md) — <!-- begin:auto-docs --> _(no submodules)_- [map](./src/transforms/map/map.md) — <!-- begin:auto-docs --> _(no submodules)_ - [map](./src/transforms/map/map.md) — <!-- begin:auto-docs --> _(no submodules)_- [sliding-bytes](./src/transforms/sliding-bytes/sliding-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_ - [sliding-bytes](./src/transforms/sliding-bytes/sliding-bytes.md) — <!-- begin:auto-docs --> _(no submodules)_- [split-join](./src/transforms/split-join/split-join.md) — <!-- begin:auto-docs --> _(no submodules)_ - [split-join](./src/transforms/split-join/split-join.md) — <!-- begin:auto-docs --> _(no submodules)_- [tap](./src/transforms/tap/tap.md) — <!-- begin:auto-docs --> _(no submodules)_ - [tap](./src/transforms/tap/tap.md) — <!-- begin:auto-docs --> _(no submodules)_- [text-codec](./src/transforms/text-codec/text-codec.md) — <!-- begin:auto-docs --> _(no submodules)_ - [text-codec](./src/transforms/text-codec/text-codec.md) — <!-- begin:auto-docs --> _(no submodules)_- [throttle](./src/transforms/throttle/throttle.md) — <!-- begin:auto-docs --> _(no submodules)_ - [throttle](./src/transforms/throttle/throttle.md) — <!-- begin:auto-docs --> _(no submodules)_- [window](./src/transforms/window/window.md) — <!-- begin:auto-docs --> _(no submodules)_ - [window](./src/transforms/window/window.md) — <!-- begin:auto-docs --> _(no submodules)_- [types](./src/types/common.md) — <!-- begin:auto-docs --> _(no submodules)_ - [common](./src/types/common.md) — <!-- begin:auto-docs --> _(no submodules)_- [buffer-to-uint8](./src/utils/buffer/buffer-to-uint8/buffer-to-uint8.md) — <!-- begin:auto-docs --> _(no submodules)_ - [buffer-to-uint8](./src/utils/buffer/buffer-to-uint8/buffer-to-uint8.md) — <!-- begin:auto-docs --> _(no submodules)_- [get-data-from-file](./src/utils/buffer/get-data-from-file/get-data-from-file.md) — <!-- begin:auto-docs --> _(no submodules)_ - [get-data-from-file](./src/utils/buffer/get-data-from-file/get-data-from-file.md) — <!-- begin:auto-docs --> _(no submodules)_- [uint8-slice](./src/utils/buffer/uint8-slice/uint8-slice.md) — <!-- begin:auto-docs --> _(no submodules)_ - [uint8-slice](./src/utils/buffer/uint8-slice/uint8-slice.md) — <!-- begin:auto-docs --> _(no submodules)_- [create-data-stream](./src/utils/stream/create-data-stream/create-data-stream.md) — <!-- begin:auto-docs --> _(no submodules)_ - [create-data-stream](./src/utils/stream/create-data-stream/create-data-stream.md) — <!-- begin:auto-docs --> _(no submodules)_- [process-data-stream](./src/utils/stream/process-data-stream/process-data-stream.md) — <!-- begin:auto-docs --> _(no submodules)_ - [process-data-stream](./src/utils/stream/process-data-stream/process-data-stream.md) — <!-- begin:auto-docs --> _(no submodules)_- [round-trip](./src/utils/stream/round-trip/round-trip.md) — <!-- begin:auto-docs --> _(no submodules)_ - [round-trip](./src/utils/stream/round-trip/round-trip.md) — <!-- begin:auto-docs --> _(no submodules)_- [validate-integrity](./src/utils/stream/validate-integrity/validate-integrity.md) — <!-- begin:auto-docs --> _(no submodules)_ - [validate-integrity](./src/utils/stream/validate-integrity/validate-integrity.md) — <!-- begin:auto-docs --> _(no submodules)_
|
|
## Installation
|
|
|
|
```bash
|
|
bun add @suaveplan/streams
|
|
```
|
|
|
|
## Modules
|
|
|
|
| Module | Description |
|
|
|---|---|
|
|
| [errors/stream-error](src/errors/stream-error.md) | `StreamError` hierarchy and `STREAM.*` error codes |
|
|
| [readable/from-array](src/readable/from-array/from-array.md) | `fromArray<T>` |
|
|
| [readable/from-generator](src/readable/from-generator/from-generator.md) | `fromAsyncGenerator<T>` |
|
|
| [readable/from-bytes](src/readable/from-bytes/from-bytes.md) | `fromBytes`, `concatByteStreams`, `sliceByteStream` |
|
|
| [transforms/map-stream](src/transforms/map-stream/map-stream.md) | `mapStream<TIn,TOut>` |
|
|
| [transforms/filter-stream](src/transforms/filter-stream/filter-stream.md) | `filterStream<T>` |
|
|
| [transforms/flat-map-stream](src/transforms/flat-map-stream/flat-map-stream.md) | `flatMapStream<TIn,TOut>` |
|
|
| [transforms/tap-stream](src/transforms/tap-stream/tap-stream.md) | `tapStream<T>` |
|
|
| [transforms/batch-stream](src/transforms/batch-stream/batch-stream.md) | `batchStream<T>` |
|
|
| [transforms/window-stream](src/transforms/window-stream/window-stream.md) | `windowStream<T>` |
|
|
| [transforms/throttle-stream](src/transforms/throttle-stream/throttle-stream.md) | `throttleStream<T>` |
|
|
| [transforms/dedup-stream](src/transforms/dedup-stream/dedup-stream.md) | `dedupStream<T>` |
|
|
| [transforms/limit-stream](src/transforms/limit-stream/limit-stream.md) | `limitStream<T>` |
|
|
| [transforms/text-codec](src/transforms/text-codec/text-codec.md) | `encodeTextStream`, `decodeTextStream` |
|
|
| [transforms/compress](src/transforms/compress/compress.md) | `compressStream`, `decompressStream` |
|
|
| [sinks/to-array](src/sinks/to-array/to-array.md) | `toArray`, `collect` |
|
|
| [sinks/to-bytes](src/sinks/to-bytes/to-bytes.md) | `toBytes`, `toString` |
|
|
| [sinks/for-each](src/sinks/for-each/for-each.md) | `forEach`, `toWritable`, `drain` |
|
|
| [pipeline/pipeline-builder](src/pipeline/pipeline-builder/pipeline-builder.md) | `pipeline()`, `PipelineBuilder` |
|
|
| [pipeline/fan-out](src/pipeline/fan-out/fan-out.md) | `fanOut` |
|
|
| [pipeline/merge](src/pipeline/merge/merge.md) | `merge` |
|
|
| [instrument/instrument-transform](src/instrument/instrument-transform/instrument-transform.md) | `instrumentTransform` |
|
|
| [node/node-adapters](src/node/node-adapters.md) | `fromNodeReadable`, `toNodeReadable`, `fromNodeWritable` |
|
|
|
|
## Quick Start
|
|
|
|
```ts
|
|
import { fromArray, mapStream, filterStream, batchStream, toArray, pipeline } from "@suaveplan/streams";
|
|
|
|
// Fluent pipeline builder
|
|
const result = await pipeline(fromArray([1, 2, 3, 4, 5, 6, 7, 8, 9, 10]))
|
|
.pipe(filterStream((n) => n % 2 === 0))
|
|
.pipe(mapStream((n) => n * n))
|
|
.pipe(batchStream(3))
|
|
.collect();
|
|
|
|
console.log(result); // [[4, 16, 36], [64, 100]]
|
|
```
|