javascript - Rxjs vänta på att föregående intervallförfrågan ska utföras innan du fortsätter
Användningsfall: ring ett slutpunkt var tredje minut som skulle uppdatera statusen för en viss tjänst över applikationen.
min nuvarande kod:
interval(180000) .subscribe(() => this.doRequest .pipe(catchError
Läs mer →javascript - Hur kan jag köra fördröjd logik med rxjs efter att ha mottagit ett värde från en prenumeration?
Jag vill köra en del av min logik efter min prenumeration med en ytterligare fördröjning (med RxJS). Jag känner till finalize-operatören, som jag skulle kunna använda med en pipe, men det skulle leda till en omedelbar körning efter att min observable ha
Läs mer →javascript - Behöver vi RXJS combineLatest med ActivateRouted.pathFromRoot?
Angular Material-dokumentationsapplikationen hämtar ruttparametrar från lata laddade ruttmoduler på detta sätt:
https://github.com/angular/material.angular.io/blob/master/src/app/pages/component-category-list/component-category-list.ts
// Combine params from all of the Läs mer →angular - AngularJS/rxjs: Observable fångar inte fel vid prenumeration
Jag försöker hantera några anpassade fel på en Observable.
Jag vill avsluta en prenumeration om jag kastar ett nytt anpassat fel. Men oavsett vad jag försöker fortsätter processen ändå utan att något fel kastas.
Jag försöker avsluta subscribe-funktionen och hoppa till felhanterare
Läs mer →angular - Hur man extraherar returvärde från store dispatch RxJs
Lång historia kort är jag junior .Net-utvecklare och jag fick i uppgift att ändra något i vår Angular-app, jag har ingen aning om hur det fungerar och jag har svårt att ändra det. Jag sitter fast på ett ämne.
Användare skapas baserat på formuläret, efter att ha skickat det finns ett anrop:
Läs mer →angular - Cachar något med RXJS tills ett visst villkor
Jag försöker skapa ett RXJS Observable som i princip ska fungera som en cache. Vanligtvis kan jag bara använda shareReplay för detta, men de data jag försöker cacha är baserade på användaren, så de måste återställas. Följande gör nästan det jag vill:
const myObservable = userProfile.pipe( switchMap(profile => loadData(profile)), shareReplay(1) );Nu är datan laddad på den första prenumerationen och den kommer inte att laddas igen förr
Läs mer →typescript - Angular 13 med RxJS 7: Hur migrerar man $obs.toPromise() till lastValueFrom($obs) med ett skript?
Jag migrerar ett Angular 12-projekt till Angular 13. Angular 13 levereras med RxJS 7. RxJS 7 har föråldrat $obs.toPromise() till förmån för lastValueFrom($obs).
Tyvärr har jag massor av $obs.toPromise() och jag letar efter ett praktiskt och tidsbesparande sätt att göra migreringen.
Finns det ett migreringsskript?
Ser i princip ut:
import * as fs from 'fs'; import * as glob from 'glob'; const files = glob.sync( Läs mer →typescript - Angular RXJS HTTPClient fångar inte fel HttpErrorResponses
Angular 12, jag försöker få en uppsättning enhetstester att köra där de ska fånga fel som kommer i http-svaret, men när testerna körs skickas felet i svarskroppen istället för som ett fel.
Spec.ts-fil
it('Test post method failure', () => { const expected: Http Läs mer →angular - typescript sortering av flera decimalpunkter med rxjs replayobject
Nedan är sorteringen för min anpassade tabellkomponent. Den fungerar bra för sträng- och taltyper förutom tal med flera decimalpunkter. DTableSort.ts
@Component({ selector: "myDefaultGSorter", template: ` <a style="cursor: pointer" (click)="sort()" class="text-nowrap" [ngClass]="isSortedByMeAsc ? 'sort_by_asc' : isSortedByMeDesc ? 'sort_by_desc' : 'no_sorting'"> <ng-conte Läs mer →typescript - rxjs-timer fortsätter att köra efter att subject complete()
Jag har följande kod för att uppnå två saker i mitt Angular 8-projekt.
- API-anrop var 30:e sekund som jag använder rxjs-timer för att hålla koll på.
- När jag mottar data via websocket vill jag kalla samma API och återställa timern till 30 sekunder.
Problem: Det verkar som att timern fortfa
Läs mer →