@systemfsoftware/rx-effect
v0.7.1
Published
Bridge RxJS and Effect-TS — turn an Observable into a typed Effect Stream with backpressure and proper interruption.
Maintainers
ryanleecodeReadme
@systemfsoftware/rx-effect
fromObservable turns an Observable<A> into a typed Stream<A, E> — values, errors, and completion map onto Effect's channels, with backpressure and proper interruption (unsubscribing the source when the stream is interrupted).
import { fromObservable } from '@systemfsoftware/rx-effect'
import { Stream } from 'effect'
import { interval } from 'rxjs'
const stream = fromObservable(interval(1000)) // Stream<number>Install
pnpm add @systemfsoftware/rx-effect[!NOTE]
effectandrxjs(v7) are peer dependencies — you bring your own.