rxjs
rxjs copied to clipboard
ReactiveX
A reactive programming library for JavaScript
withLatestFrom and sample are pretty similar: the latter just skips emitting when the sampled observable hasn't emitted anything new. I recently found myself using sample when I should've been using...
**Description:** Typos in docs **BREAKING CHANGE:** **Related issue (if exists):**
**Description:** This PR makes the `observerOrNext` param in `Observable#subscribe`. No logic change is required, as `subscribe` is already overloaded with `null`, so the logic to check for this [is already...
### Describe the bug the following code is correct, but will generate a false error ``` import { Observable, of, tap } from 'rxjs'; let test$: Observable = of(1).pipe( tap(()...
### Describe the bug Hello! I've encountered an error in rxjs published as latest (7.8.1 as of writing this) I've built a simple iterable structure for a specific task. It...
## Feature Request rxjs/webSock should support deserializer return Promise **Is your feature request related to a problem? Please describe.** ```javascript import { webSocket } from 'rxjs/webSocket' const api = (options)...
**Description:** We need the ability to delegate and dispose timers independently within `beforeEach/afterEach`. The `createDelegates` method is currently private, preventing its use. We must resort to a workaround: executing `scheduler.run(()...
### Describe the bug Calling `.next()` with no arguments like this ``` new Observable((observer) => { observer.next() } ``` shows error ``` Expected 1 arguments, but got 0.ts(2554) Subscriber.d.ts(42, 10):...
### Describe the bug The following code shows a weird behavior of `.pipe()`: ```js const RxJs = require('rxjs'); const mySubj$ = new RxJs.Subject(); const doubled$ = mySubj$.pipe( RxJs.map((v) => v...
According to the docs you can omit the comparator in `distinctUntilChanged`. The typings however forbid this. According to code comments passing null was previously supported. Not sure if that should...
