angular - Returner resultatet av en observable med combineLatest og Rxjs
Jeg ønsker å få resultatet av en observable som trekker fra standardverdien hver gang verdien endres
Hver gang verdien endres, trekker den standardverdien fra den nye verdien som er skrevet inn i inndatafeltet
For eksempel er standardverdien 5.
Jeg skriver 4 i inndatafeltet
Les mer →angular - Hvordan få tilgang til Rx.Scheduler.immediate gjennom rxjs ved bruk av SystemJS/Angular2?
Jeg vil gjerne bruke ImmediateScheduler fra RxJS i mitt Angular2-prosjekt.
Men i min RxJS-installasjon finnes dette ikke. Jeg bruker "rxjs": "5.0.0-beta.12" i min package.json som kreves av Angular 2.1.2.
Når jeg ser i node_modules/-mappen finner jeg en mappe 'rxjs' og en mappe 'rx'. ImmediateScheduler er ikke en del av 'rxjs' men av 'rx'. Jeg kan finne det der i 'rx/dist/rx.lite.js' eller til og med i 'rx/ts/rx/rx-lite.ts' som TypeScript som jeg bruker.
Prøver å importere det
Les mer →typescript - Rxjs: kortform for å opprette observable fra verdi eller observable
Jeg bruker rxjs med TypeScript. Jeg har skrevet følgende to enkle funksjoner. Men jeg antar at rxjs allerede har slik funksjonalitet. Har rxjs det?
export function isObservable(value: any): value is Observable<any> { return value in Les mer →typescript - Firebase og RxJS
Jeg lagde en funksjon som lytter til verdihendelser:
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 endres,
Les mer →angular - RXJS-operatører fungerer ikke med firebase
Jeg bruker RXJS-operatørene med Firebase-observablen (distinct og filter). Dette er Firebase-treet mitt her. Dette er koden min:
let places this.db.list(`users/${this.authProvider.getUID()}/visitedPlaces`,{ query:{ orderByChild:"googleId" } }); places.distinct((p)=>{ console.log(p) Les mer →javascript - Typescript-modul løser 'rxjs' forskjellig i samme fil
Jeg har brukt timer på å gå i sirkler, så det er på tide med et annet obskurt spørsmål.
Jeg er inne i et lerna mono-repo, med to delprosjekter, ProjectA og ProjectB.
ProjectA har en avhengighet av rxjs, det samme g
Les mer →typescript - RxJS6: tilbakestill strøm etter fullføring
Jeg har lekt litt med RxJS 6. Jeg prøver å implementere dragstart, dragmove og dragend. Dette er koden jeg har så langt.
import { fromEvent } from 'rxjs'; import { concatMap } from 'rxjs/internal/operators/concatMap'; import { map } from 'rxjs/internal/operators/map'; import { takeUntil } from 'rxj Les mer →typescript - Med RxJs i Angular, trenger jeg bare å fullføre Observables opprettet i komponenten?
Egentlig er jeg fortsatt ikke helt sikker på oppryddingen av reaktiv kode i Angular-komponenter. Er de følgende reglene riktige og tilstrekkelige?
Mine regler for en reaktiv komponent:
på manual x.subscribe():
- hvis du bruker x.takeUntil(...) eller lignende konstruksjon, ingen manuell opprydding
- hvis x.complete() kalles i komponentområdet, er ingen manuell opprydding nødvendig
- ellers manuell .unsubscribe() Les mer →
typescript - rxjs paginering med abonnement på hver side
Vi forespør graphql over websocket for å ha et abonnement på en liste over enheter. Vi bruker paginering siden listen skal kunne rulles uendelig. Vi ønsker også å se endringer gjort i databasen i sanntid i listen på front-end.
Denne listen kan filtreres, sorteres og paginere.
Vi har klassen SelectParams som hjelper oss med å gjøre det:
export class SelectParams { page = 0; query = ''; sort: Les mer →typescript - Angular 6 Feil ved bruk av RxJS: Kan ikke lese egenskapen 'call' av undefined
Jeg prøver å migrere en Angular 5-app til Angular 6, og jeg har denne ene blokken med RxJS-kode som får meg til å gå i stå. Jeg har googlet og lest gjennom RxJS-dokumentasjonen nok til å vite at jeg burde bruke .pipe, men jeg får ikke helt taket på syntaksen.
Koden returnerer
Les mer →