angular - Returnează rezultatul unui observable cu combineLatest și Rxjs
Doresc să obțin rezultatul unui observable care scade valoarea implicită de fiecare dată când valoarea se schimbă
De fiecare dată când valoarea se modifică, scade valoarea implicită cu noua valoare introdusă în câmpul de input
De exemplu, valoarea implicită este 5.
Introduc 4 în
Citeste mai mult →angular - Cum să accesez Rx.Scheduler.immediate prin rxjs folosind SystemJS/Angular2?
Aș dori să folosesc ImmediateScheduler din RxJS în proiectul meu Angular2.
Totuși, în instalarea mea de RxJS, acest lucru nu există. Folosesc „rxjs”: „5.0.0-beta.12” în fișierul meu package.json, care este necesar de Angular 2.1.2.
Când mă uit în folderul node_modules/, găsesc un folder „rxjs” și un folder „rx”. ImmediateScheduler nu face parte din „rxjs”, ci din „rx”. Îl pot găsi acolo în „rx/dist/rx.lite.js” sau chiar în „rx/ts/rx/rx-lite.ts” ca TypeScript, pe care îl folosesc.
typescript - Rxjs: prescurtare pentru a crea un observable dintr-o valoare sau observable
Folosesc rxjs cu TypeScript. Am scris următoarele două funcții simple. Dar cred că rxjs are deja o astfel de funcționalitate. Are rxjs?
export function isObservable(value: any): value is Observable<any> { return value instanceof Obs Citeste mai mult →typescript - Firebase și RxJS
Am creat o funcție care ascultă evenimente de valoare:
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); }) }) }Când baza de date se
Citeste mai mult →angular - operatorii RXJS nu funcționează cu firebase
Folosesc operatorii RXJS cu observable-ul Firebase (distinct și filter). Acesta este arborele meu Firebase aici. Acesta este codul meu:
let places this.db.list(`users/${this.authProvider.getUID()}/visitedPlaces`,{ query:{ orderByChild:"googleId" } }); places.distinct((p)=>{ console.lo Citeste mai mult →javascript - Modulul Typescript rezolvă 'rxjs' diferit în același fișier
Am petrecut ore întorcându-mă în cercuri, așa că e timpul pentru o altă întrebare obscură.
Sunt în interiorul unui mono-repozitoriu lerna, cu două subproiecte, ProjectA și ProjectB.
ProjectA are o dependență de rxjs
Citeste mai mult →typescript - RxJS6: resetarea fluxului după finalizare
M-am jucat puțin cu RxJS 6. Încerc să implementez dragstart, dragmove și dragend. Acesta este codul pe care îl am până acum.
import { fromEvent } from 'rxjs'; import { concatMap } from 'rxjs/internal/operators/concatMap'; import { map } from 'rxjs/internal/operators/map'; import { takeUntil } from Citeste mai mult →typescript - Cu RxJs în Angular, trebuie să finalizez doar Observables create în componentă?
Practic, încă nu sunt foarte sigur cu privire la curățarea codului reactiv din componentele Angular. Sunt regulile următoare corecte și suficiente?
Regulile mele pentru un component reactiv:
pe manual x.subscribe():
- dacă folosiți x.takeUntil(...) sau un construct similar, atunci nu este necesară curățarea manuală
- dacă x.complete() este apelat în cadrul componentului atunci nu este necesară nicio curățare manuală
- al Citeste mai mult →
typescript - paginare rxjs cu abonament la fiecare pagină
Interogăm graphql prin websocket pentru a avea o abonare la o listă de entități. Folosim paginare deoarece lista ar trebui să fie derulabilă la infinit. De asemenea, dorim să vedem modificările făcute în baza de date în timp real în listă pe front-end.
Această listă poate fi filtrată, sortată și paginată.
Avem clasa SelectParams care ne ajută să facem asta:
export class SelectParams { page = 0; Citeste mai mult →typescript - Angular 6 Eroare folosind RxJS: Nu se poate citi proprietatea 'call' din undefined
Încerc să migrez o aplicație Angular 5 la Angular 6 și am acest bloc de cod RxJS care mă depășește. Am căutat pe Google și am citit suficient documentația RxJS pentru a ști că ar trebui să folosesc .pipe, dar nu reușesc să înțeleg exact sintaxa.
Codul returnează rezultate dint
Citeste mai mult →