datastream

Streams made easy. Commonly used stream patterns for Web Streams API and NodeJS Stream. Modular, composable, and lightweight.

Get started

100k+

Weekly downloads
Lightweight

Fewer dependencies
96%+

Test coverage

Everything you need for stream processing

Dual platform

Works with both Web Streams API and Node.js Streams. Write once, run anywhere — server, browser, or edge.
Modular

Install only what you need. Each stream type is a separate package, keeping your bundle size minimal.
Composable pipeline

Chain readable, transform, and writable streams together with a simple pipeline() call. Build complex data flows from simple parts.
Common patterns included

CSV parsing, compression, character encoding, validation, base64, cryptographic digests — all the patterns you commonly need, ready to use.
AWS integrations

Stream data to and from DynamoDB, S3, SQS, SNS, and Lambda with purpose-built stream adapters.
Lightweight

Zero-bloat design. Each package has minimal dependencies and small install size, perfect for serverless and edge environments.

Show me the code!

Build a complete data pipeline in just a few lines:

  import { pipeline, createReadableStream } from '@datastream/core'
import { csvParseStream } from '@datastream/csv'
import { validateStream } from '@datastream/validate'
import { gzipCompressStream } from '@datastream/compress'

const streams = [
  createReadableStream(csvData),
  csvParseStream({ header: true }),
  validateStream(schema),
  gzipCompressStream()
]

await pipeline(streams)