Is there any tool or technique to detect "left behind" or "currently alive" observables, subscriptions.  Just recently discovered a pretty nasty memory leak where components were kept alive due to missing "unsubscribe" calls....

I've created a demo (ng-run) where I have a button which invokes an Http request.  When the button is clicked, I invoke this method :   public getData(){  this._jokeService.getData().subscribe(); }   Which in turn invokes this ( from a service) :...

Let's imagine i have a function fetchUser which takes as parameter userId and return an observable of user.   As i am calling this method often, i want to batch the ids to perform one request with multiple ids instead !  Here my troubles began......

valueChanges Observable which exists on FormControl object emits value each time setValue(value) function gets called on FormControl object.  Using RxJS operator distinctUntilChanged we can filter out values which aren't new. But this doesn't...

I have this piece of code where I am trying to capture all the drag events. This code works only for the first drag and stop will not work for successive drags.  Is it because takeUntil cancelling the outer observable? How can I make the code work....

Things I have tried include following where values is array of values of which I want to find the sum.  I have also added necessary functions from rxjs as follows: I get an error saying      typeError: Rx.Observable.from(...).sum is not a function...

I have an array of data which describes entity relationships. My code:  services             .tree             .collection             .find()             .$             .pipe(                 switchMap(from),                 groupBy((value) => va...

I am trying filtering the return of HTTP request in Angular 7 using RXJS6.  I must filter the response; only get the Users with IdSkill equals to 1234.  However, I cannot achieve this. I just received this error:  Type 'Observable' is not ass...

I would like to allow a client to dynamically change the url to a webSocket and maintain Observables on connection to the new webSocket. Looking over the RxJS Github and Stackoverflow, this is not something that is supported by RxJS (see https://gith...

Use case: Call a function every minute (60000 ms) that dispatches store action to fetch lastUpdated status of items, which upon response and filtering, updates the store, and updated store is read as an observable and displayed in the view). This nee...