I have some problem trying to understand why do I need to pipe share operator at the outer observable when trying to make shared observable. I would think that it will be sufficient to pass share as part of observable…
I have an Observable containing an array that i use in the UI with an async pipe to display a table of contracts. One column in that table shows a status value which is 'not processed' on page load. contracts$:…
How should be go about using / observing parent @Output() event emitters in child components? For example in this demo the child component uses the @Output onGreetingChange like this: <app-greeting [greeting]="onGreetingChange | async"></app-greeting> And this will work if onGreetingChange emits…
I have 3 observables: query$ = this.q$.pipe(tap(() => this.page$.next(0)); filter$ = this.f$.pipe(tap(() => this.page$.next(0)); page$ = new BehaviorSubject<number>(0); combinetLatest({ query: this.query$, filter: this.filter$, page: this.page$ }) .pipe( switchMap(({ query, filter, page }) => { ... }) ); I have to…
Trying to figure out why OnPush change detection strategy is not working In this demo. If I understand correctly OnPush change detection should be triggered when a property reference changes. and in order to ensure this a new array is…
I am trying to utilse some of Angular's new reactivity with Signal. I am following this workflow, and converting one of my observables into a signal, this is then being read and displayed on my screen. https://angular.dev/guide/signals/rxjs-interop#tosignal Working Example **…
I am facing an issue with the execution order of recursive RxJS Observables in an Angular application. I have a service, RefreshReportService, which is responsible for refreshing reports. The refreshreport method is designed to refresh a report and its nested…
I use the same error handling for multiple rxjs functions: f1() { this.error = undefinded; //* obs1$.subscribe({ next: () => some_code, error: error => this.error = error //* }) } f2() { this.error = undefinded; //* obs2$.subscribe({ next: () =>…
I want to combine two subjects in similar way as zip does, but with the following important difference. I want an observables that combines two subjects in this way. When both have emitted values, emit the latest of their values.…
In RxJS, how can I achieve this: I have two subjects. I want an observables that combines them in this way: When both have emitted values, emit the latest of their values. Then, both need to emit at least once…