Pipeljs
A Promise-like Reactive Stream Library
🚀 Features
- 🤞 Easy to Use: Promise-like stream processing with chainable APIs
- 🔄 Reactive Programming: Observable-based data streams
- ⚡ Async Control: Powerful Promise-like async flow control
- 🛠️ Rich Operators: A wide range of transformation and combination operators
- 🔌 Plugin System: Extensible plugin mechanism for debugging and logging
- 💾 Immutable Operations: Immutable data updates powered by limu
- 🎯 TypeScript: Fully typed for a smooth developer experience
📦 Installation
npm install pipeljs
yarn add pipeljs
pnpm add pipeljs
Quick Start
import { $ } from 'pipeljs'
const stream$ = $()
stream$.then((value) => {
console.log('received:', value)
})
stream$.next('Hello Pipel!')