I want to implement a logic where if there is no network connectivity then i am storing the data in frontend in local storage and whenever got connected to network then I want to do api call on the this array of data from local storage. And if call is success then remove this item from storage and continue th…
Tag: rxjs
How to detect changes in child component with respect to changes in the base component – Angular
I have a component profile.component.ts in which there’s a variable, this.candidate, which subscribes to and gets updated like this This component acts like a base component and there’s a child component that extends this component, Now I want to have another variable in this child component that …
Identify origin of an observable event on subscription
I have a BehaviorSubject<Array<user>> (userListSub$) state that is updated from various places. For example, when I click Follow on a user when I click Unfollow on a user when I favorite a user The same state is being subscribed in different components. I would like a particular component to not r…
await operator is being skipped
Could you please help me with an issue I am facing? I have attached my code below, after button click, it catches an error (if there is) but skips Which means it just jumps to catch (e). I need it to reload my grid first. Thank you for any advise. Answer If it skips over your code like that, chances
avoid nested subscribe if there is a forkjoin inside
Here is my code in angular So there are many levels of subscribe. Not only it is ugly also the result is wrong and I can’t not find it out by debugging. How can I rewrite it with rxjs operators? Answer You can simplify it using the RxJS operators, like the following: Note: To handle the memory leaks, it…
Angular-Listening to store changes & emit a value from a Service component to a different component – only after Service completes certain operations
Here we have to classes GetDataAsyncService which waits for change in the store (and not executes the block of code under it until a change in the store ( this.getDataAsyncService.getAsyncData().subscribe((data)=>{ )}). When it is called from MainComponent it will get return of(propA); (from GetDataAsyncSe…
angular 13: Module not found: Error: Can’t resolve ‘rxjs/operators’
I have upgraded my angular to angular 13. when I run to build SSR it gives me following error. my package.json file: Any Idea Answer I just solve this issue by correcting the RxJS version to 7.4.0. I hope this can solve others issue as well.
Angular display template if observable is falsey with async pipe
I have an API call that may return some data or may return something falsey if no data exists. If there is data, I want to tap out of the stream and do some side effects, but if falsey, I want no side effects to happen but still display my template code. I am using an async pipe to get
How to Map/reduce a series of date bound values to a running total in JavaScript / RXJS?
I have an observable that emits measurement values with a date for a key. Something like: I need a 7 days running total and average for temp and hum. If I would have a a value for each week, I could write: However I need a running total where the values are accumulated like this: How would I design a
RxJS – Processing HTTPrequests in sequence
I’m currently trying to process HTTP Post requests in sequence, additionally trying to repeat each failed request until it succeeds (that is a requirement) and then and only then to continue with processing other requests. My code looks like this for now (it not working as it should, retryWhen is not us…