javascript - Rxjs vent på, at den forrige intervalanmodnings udførelse er færdig, før du fortsætter
Brugssag: kald et endepunkt hvert 3. minut, som ville opdatere status for en bestemt tjeneste i applikationen.
min nuværende kode:
interval(180000) .subscribe(() => this.doRequest .pipe(catchError(() =>
Læs mere →javascript - Hvordan kan jeg køre forsinket logik med rxjs efter at have modtaget en værdi fra et abonnement?
jeg vil køre en del af min logik efter mit abonnement med en ekstra forsinkelse (med RxJS). Jeg kender til finalize-operatoren, som jeg kunne bruge med en pipe, men det ville føre til en øjeblikkelig udførelse efter afslutningen af mit observable.
Læs mere →javascript - Har vi brug for RXJS combineLatest med ActivateRouted.pathFromRoot?
Angular Material-dokumentationsapplikationen henter ruteparametre fra lazy-loaded rutemoduler på denne måde:
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 pa Læs mere →angular - AngularJS/rxjs: Observable fanger ikke fejl ved abonnement
Jeg prøver at håndtere nogle brugerdefinerede fejl på en Observable.
Jeg vil afslutte et abonnement, hvis jeg kaster en ny brugerdefineret fejl. Men uanset hvad jeg prøver, fortsætter processen stadig uden, at der kastes nogen fejl.
Jeg prøver at afslutte subscribe-funktionen og s
Læs mere →angular - Hvordan man udtrækker returværdi fra store dispatch RxJs
For at gøre en lang historie kort, jeg er junior .Net-udvikler, og jeg har modtaget en opgave om at ændre noget i vores Angular-app. Jeg har ingen idé om, hvordan det fungerer, og jeg kæmper for at ændre det. Jeg sidder fast på ét emne.
Brugeren oprettes baseret på formularen, efter at den er indsendt,
Læs mere →angular - Cache noget med RXJS indtil en bestemt betingelse
Jeg prøver at lave en RXJS Observable, som i det væsentlige vil fungere som en cache. Normalt kan jeg bare bruge shareReplay til dette, men de data, jeg prøver at cache, er baseret på brugeren, så de skal nulstilles. Følgende gør næsten det, jeg vil:
const myObservable = userProfile.pipe( switchMap(profile => loadData(profile)), shareReplay(1) );Nu er dataen indlæst på det første abonnement, og den vil ikke blive indlæst igen, før en
Læs mere →typescript - Angular 13 med RxJS 7: Hvordan migrerer man $obs.toPromise() til lastValueFrom($obs) med et script?
Jeg migrerer et Angular 12-projekt til Angular 13. Angular 13 leveres med RxJS 7. RxJS 7 har udfaset $obs.toPromise() til fordel for lastValueFrom($obs).
Desværre har jeg tonsvis af $obs.toPromise(), og jeg leder efter en praktisk og tidsbesparende måde at foretage migrationen på.
Er der et migrationsscript?
Grundlæggende ser ud:
import * as fs from 'fs'; import * as glob from 'glob'; const files = glob.sync(` Læs mere →typescript - Angular RXJS HTTPClient fanger ikke fejl HttpErrorResponses
Angular 12, jeg prøver at få et sæt enhedstests til at køre, hvor de vil fange fejl, der kommer i http-svaret, men når testene kører, bliver fejlen sendt i svarbodyen i stedet for som en fejl.
Spec.ts-fil
it('Test post method failure', () => { const expected: Læs mere →angular - typescript sortering af flere decimaler ved hjælp af rxjs replayobject
Nedenfor er sorteringen af min tilpassede tabelkomponent. Den fungerer godt for streng- og taltyper undtagen tal med flere decimaler. 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-content Læs mere →typescript - rxjs-timer kører stadig efter subject complete()
Jeg har følgende kode for at opnå 2 ting i mit Angular 8-projekt.
- API-opkald hvert 30. sekund, som jeg bruger rxjs-timer til at holde styr på.
- Hver gang jeg modtager data via websocket, vil jeg kalde den samme API og nulstille timeren til 30 sekunder.
Problem: Det ser ud til, at timeren
Læs mere →