Questions tagged [rxjs-pipe]

7 questions
187
votes
5 answers

What is pipe() function in Angular

Pipes are filters for transforming data (formats) in the template. I came across the pipe() function as below. What does this pipe() function exactly mean in this case? return this.http.get(url) .pipe( tap(_ => this.log(`fetched hero…
Dinesh Sharma
  • 2,117
  • 3
  • 13
  • 9
3
votes
1 answer

How to continue catchError in timer (rxjs)

I have a service that is responsible to execute a httpClient.get every x seconds, using a timer. I need this timer to start running whenever the service is up, so the timer is defined in the service constructor. According to my understanding, the…
Guy E
  • 1,775
  • 2
  • 27
  • 55
2
votes
1 answer

Best practices for avoiding memory leaks in angular

I'm trying detect and fix potential memory leaks in my angular/spartacus application. So basically I'm looking for any "subscribe(..." calls in my code base and evaluate what I can do. I know that simplest form is simply to use observables directly…
1
vote
1 answer

onClick to subscribe to observable. Action expression cannot contain pipes

Hi I have a ShopItemComponent. I want it to take a function as an input so that when a button in shop-item.component.html is clicked, the function gets called. inside the function in shop-item.component.html is an observable, the function subscribes…
STH
  • 73
  • 6
1
vote
1 answer

Angular and RxJS - subscribe function for forkjoin not executing

In the code below, the subscribe function is not run ('Never called' does not appear in the console); however, the three services are called. ngOnInit(): void { forkJoin([this.adminBCService.getAvailableBusinessCases(),…
nstuyvesant
  • 1,392
  • 2
  • 18
  • 43
0
votes
0 answers

Angular - rxjs : How to add filter to check if measures.length > 0 and then proceed with tap

I am new to Angular and rxjs. Please guide me how can I apply filter to check if data is available in 'measures' before opening the _showMeasureSelectionModal in the following function. selectMeasure() { combineLatest([this.configure.measure$,…
Tidi
  • 95
  • 1
  • 6
0
votes
2 answers

Angular Rxjs: Have concat wait for a very long tap

I'm trying to automatize a process of updating some data in the backend of my program. I'm using my Angular frontend, where I created a function only the master user can access and that should make him login in every administration (tenant), where…