xstream icon indicating copy to clipboard operation
xstream copied to clipboard

An extremely intuitive, small, and fast functional reactive stream library for JavaScript

Results 52 xstream issues
Sort by recently updated
recently updated
newest added

When a throttled stream is unsubscribed, its internal throttle interval is not cleared, and the reference to its ID is removed, meaning it's also not cleared at the end of...

Bumps [shell-quote](https://github.com/substack/node-shell-quote) from 1.6.1 to 1.7.3. Release notes Sourced from shell-quote's releases. v1.7.2 Fix a regression introduced in 1.6.3. This reverts the Windows path quoting fix. (144e1c2) v1.7.1 Fix $...

dependencies

`filter` on a MemoryStream was returning a Stream because we assumed that it would "remove" values, and a MemoryStream cannot have no value. But in fact a MemoryStream can have,...

The current proxy design using .imitate is kinda a unusual api in world where almost all other stream creation operators are pure, and typescript can't automatically infer its type since...

When working in Js without Typescript help the lib don't warn you when passing bad values to stream constructor A classic example is merging or composing null values: const stream1...

Hey folks! I found a strange behavior of `sampleCombine`. It reproduces in case of: `input.compose(sampleCombine(derivedFromInput, independentOfInput))` - only when: - some `derivedFromInput` (or just same `input`) is the first parameter...

logic error, rearrange code order.

`imitate` was deemed necessary long ago before we had `@cycle/state` and other facilities. Internally, it requires significant "machinery" to work. For instance, see private methods `_hasNoSinks` (recursive!) and `_pruneCycles`. Nowadays,...

I'm currently profiling a cyclejs app and scope hoisting is not possible with xstream because of missing ES6 build. The problem is again with the extra imports. The same problem...

This PR: - enforces TS `strict` mode on the whole repo - makes `Stream` covariant on `T` by modifying inner `_ils`, `_dl` types. ```ts const s$: Stream = xs.create() ```