V2.3.2: Rxs

source$.pipe( filter(x => x > 1), map(x => x * 10) ).subscribe( next: (val) => console.log(val), // 20, 30 complete: () => console.log('done') ); ✅ No breaking changes – simply update the version and re-run tests.

import Observable from 'rxs'; import map, filter from 'rxs/operators'; const source$ = new Observable<number>(subscriber => subscriber.next(1); subscriber.next(2); subscriber.next(3); subscriber.complete(); ); rxs v2.3.2

yarn add rxs@2.3.2 // package.json

"dependencies": "rxs": "2.3.2"

| Area | Expected Change | |------|----------------| | | Fixed subscription disposal in Subject when error occurs during stream cleanup. | | Operator edge case | Corrected debounceTime not firing last value on completion. | | TypeScript types | Improved overload signatures for combineLatest and zip . | | Performance | Reduced object allocations in pipe() chain. | | Build | Updated dependencies (e.g., tslib , core-js ). | 4. Installation (Example – npm for JS/TS) npm install rxs@2.3.2 or source$