1,510
questions
0
votes
2
answers
45
views
Angular 16 RxJs Issue Updating Total on Header Component
Hello I have an question regarding my Observable.
I have a cart as well as checkout that works fine when I add a another items to cart
it handles total items as well as total cost. These components ...
2
votes
1
answer
81
views
Why does RXJS Observable stops emitting after getting error
I am trying to access datas every time the user changes the input value.
The search can return an error.
In this case, I want to disable the use of AI (semanticDisabled) for future searchs and then ...
0
votes
1
answer
67
views
Timeout stops stream rxjs Angular
Hi i want to keep getting data even after the timeout its reached i try some other way but no success (timeWith, repeatWhen ect)
here my code. now, any help would be good
goal: Device stops sending ...
0
votes
0
answers
32
views
Shield observable chain
I have this RxJS observable chain. I want to remove final error handling (since there is some error handling in chain which I need there) from chain and leave it to Global error handler. Whatever I ...
0
votes
1
answer
33
views
rxjs 5 -> 6 migration: connect operator missing
We started upgrading rxjs from v5 to v6 (without using the compatibility layer, in case it makes any difference).
The majority of the changes are straight forward and well documented in https://github....
0
votes
0
answers
174
views
Angular module's provider service is acting as singleton even though that module is imported in other feature modules
As per angular document - https://angular.io/guide/singleton-services
If a module defines both providers and declarations (components, directives, pipes), then loading the module in multiple feature ...
0
votes
1
answer
77
views
How to take some of the properties of an Observable and assign them to another Observable using RxJS operators
I have an employee$ Observable and a personalInformation$ Observable. personalInformation$ is a subset of employee$ and I want to map the matching properties of employee$ to personalInformation$. The ...
1
vote
0
answers
70
views
How to make my newly created observable subscribers to get a boolean?
I want to make an observable that when a subscribed to emits a boolean , i tried a lot of combinations but nothing seems to work.
example:
let myObservable = new Observable<boolean>(item => ...
1
vote
1
answer
1k
views
How to import firstValueFrom function from rxjs in Angular 13?
Module '"rxjs"' has no exported member 'firstValueFrom'.ts(2305)
0
votes
2
answers
3k
views
How do I combine two subscriptions in Angular?
Is there a way to combine the subscriptions for this.controls.attendanceDate and this.controls.type? I need to have access to both at the same time in order to call each of this....
0
votes
2
answers
131
views
RxJS operator equivalent of ((observableX | async) || (observableY | async)) in template
I have the following code in my component template
<mat-spinner *ngIf="((facade.user.data$.isLoading | async) || (facade.product.data$.isLoading | async))"></mat-spinner>
I want ...
-1
votes
1
answer
520
views
Call a method from inside of subscribe
Im trying to call a method from inside of subscribe in angular/ionic. But its not working. Here is my code:
somemethod()
{
const browser = this.iab.create('https://someurl.com');
browser.on('...
1
vote
1
answer
2k
views
Angular: intercept an HttpResponse and make other calls before propagate the response to caller
What i'm trying to do is to intercept a response and if here is a certain value (CHALLENGE), make a call to an other API and retry it 3 times if needed, then, if success, reply the first call and ...
0
votes
0
answers
399
views
Subject import package difference
I got a warning when I serve my Angular app.
depends on 'rxjs/internal/Subject'. CommonJS or AMD dependencies can cause optimization bailouts.
But when I changed Subject import package.The warning ...
0
votes
2
answers
1k
views
how to flatten the nested array in rxjs
I am using forkJoin to subscribe multiple inner observable. How can I flat nested array to single level array.
const x$ = of([1, 2, 3, 4]);
const y$ = of([2, 4]);
x$.pipe(
switchMap((t) => {
...