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 have an action that I want to use to initialise my app, I want to create an epic for this action and then fire multiple other actions off the back of this, wait for them to all complete and there fire another action. I had a look at other questions...
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) :...
I want to send request using this code (i've tried forkJoin too) with a delay between calls: duplicateElement(id: string): Observable<any> { return this.http.get({ routeName: 'route_name', params: { id } }); } duplicateElement...
I am using the latest version of redux-observable and Rxjs i.e // My version "redux-observable": "^1.0.0", "rxjs": "^6.3.2" The store - middleware, setup looks like this: // Setting up middlewares import { pingEpi...
The abstract problem Is there any way to consume the result of a mergeMap in the original order of the outer observable, while still allowing the inner observables to run in parallel? More detailed explanation Let's look at two merge-mapping...
Why do we use two filters in code below instead one? fromEvent<MouseEvent>(this.mapElement, "click") .pipe( filter(e => !this.props.disableEvents), filter(_ => !this.mouseState.moved && mouseDownInMap...
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......
i'm trying to create a reusable Modal component. in a ModalService i have a Subject, and a method that that calls next() on the subject. The ModalComponent subscribes to that subject, but whenever the method in the service is being called, the ne...
I have a method that returns an observable as follows constructor(private _http: HttpClient) {} getUsers(location){ return this._http.get(`https://someurl?location=${location}`) .pipe( map((response: any) => response),...
©2020 All rights reserved.