angular - Returner resultatet af en observable med combineLatest og Rxjs
Jeg ønsker at få resultatet af et observerbart, som trækker standardværdien fra, hver gang værdien ændrer sig
Hver gang værdien ændres, trækker den standardværdien fra med den nye værdi, der indtastes i inputfeltet
For eksempel er standardværdien 5.
Jeg indtaster 4 i inputfeltet
Læs mere →angular - Hvordan får man adgang til Rx.Scheduler.immediate gennem rxjs ved brug af SystemJS/Angular2?
Jeg vil gerne bruge ImmediateScheduler fra RxJS i mit Angular2-projekt.
Men i min RxJS-installation findes dette ikke. Jeg bruger "rxjs": "5.0.0-beta.12" i min package.json, som kræves af Angular 2.1.2.
Når jeg ser i node_modules/-mappen, finder jeg en mappe 'rxjs' og en mappe 'rx'. ImmediateScheduler er ikke en del af 'rxjs', men af 'rx'. Jeg kan finde den der i 'rx/dist/rx.lite.js' eller endda i 'rx/ts/rx/rx-lite.ts' som TypeScript, som jeg bruger.
Forsøger at importere det
Læs mere →typescript - Rxjs: forkortelse for at oprette en observable fra en værdi eller observable
Jeg bruger rxjs med TypeScript. Jeg har skrevet følgende to simple funktioner. Men jeg tror, rxjs allerede har en sådan funktionalitet. Har rxjs det?
export function isObservable(value: any): value is Observable<any> { return value Læs mere →typescript - Firebase og RxJS
Jeg lavede en funktion, der lytter til værdihændelser:
getUnreadMessages() : Observable<any>{ return new Observable(observer =>{ firebase.database().ref('messages/' + this.userService.getUserID()).on("value", (snapshot : any) =>{ let count = 0; ...some more logic here... observer.next(count); observer.complete(); }, (error) =>{ observer.error(error); }) }) }Når databasen ændrer
Læs mere →angular - RXJS-operatører virker ikke med firebase
Jeg bruger RXJS-operatørerne med Firebase-observablen (distinct og filter). Dette er mit Firebase-træ her. Dette er min kode:
let places this.db.list(`users/${this.authProvider.getUID()}/visitedPlaces`,{ query:{ orderByChild:"googleId" } }); places.distinct((p)=>{ console.log(p) ret Læs mere →javascript - Typescript modulopløsning af 'rxjs' forskelligt i samme fil
Jeg har brugt timer på at gå rundt i cirkler, så det er tid til endnu et obskurt spørgsmål.
Jeg er inde i et lerna mono repo, med to underprojekter, ProjectA og ProjectB.
ProjectA har en afhængighed af rxjs, ligeso
Læs mere →typescript - RxJS6: nulstil strøm efter fuldførelse
Jeg har leget lidt med RxJS 6. Jeg prøver at implementere dragstart, dragmove og dragend. Dette er koden, jeg har indtil videre.
import { fromEvent } from 'rxjs'; import { concatMap } from 'rxjs/internal/operators/concatMap'; import { map } from 'rxjs/internal/operators/map'; import { takeUntil } f Læs mere →typescript - Med RxJs i Angular, skal jeg kun afslutte de Observables, der er oprettet i komponenten?
Grundlæggende er jeg stadig ikke helt sikker på oprydningen af reaktiv kode i Angular-komponenter. Er de følgende regler korrekte og tilstrækkelige?
Mine regler for en reaktiv komponent:
på manuel x.subscribe():
- hvis du bruger x.takeUntil(...) eller en lignende konstruktion, er der ingen manuel oprydning
- hvis x.complete() kaldes i komponentens område, så er der ingen manuel oprydning
- ellers manuelt .unsubscribe Læs mere →
typescript - rxjs pagination med abonnement til hver side
Vi forespørger graphql over websocket for at have en abonnement på en liste af enheder. Vi bruger paginering, da listen forventes at kunne rulles uendeligt. Vi vil også gerne se ændringer foretaget i databasen i realtid i listen på frontenden.
Denne liste kan filtreres, sorteres og paginere.
Vi har klassen SelectParams, som hjælper os med at gøre det:
export class SelectParams { page = 0; query Læs mere →typescript - Angular 6 Fejl ved brug af RxJS: Kan ikke læse egenskaben 'call' af undefined
Jeg prøver at migrere en Angular 5-app til Angular 6, og jeg har denne ene blok af RxJS-kode, der forvirrer mig. Jeg har googlet og læst RxJS-dokumentationen nok til at vide, at jeg bør bruge .pipe, men jeg kan ikke helt finde ud af syntaksen.
Koden returnerer resultater fra e
Læs mere →