# @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]]
```