angular - Returnera resultatet av en observable med combineLatest och Rxjs
Jag önskar få resultatet av ett observerbart som subtraherar standardvärdet varje gång värdet ändras
Varje gång värdet ändras subtraherar det standardvärdet med det nya värdet som anges i inmatningsfältet
Till exempel är standardvärdet 5.
Jag skriver 4 i inmatningsfältet
R
Läs mer →angular - Hur man får tillgång till Rx.Scheduler.immediate genom rxjs med SystemJS/Angular2?
Jag skulle vilja använda ImmediateScheduler från RxJS i mitt Angular2-projekt.
Men i min RxJS-installation finns detta inte. Jag använder "rxjs": "5.0.0-beta.12" i min package.json vilket krävs av Angular 2.1.2.
När jag tittar i node_modules/-mappen hittar jag en mapp 'rxjs' och en mapp 'rx'. ImmediateScheduler är inte en del av 'rxjs' utan av 'rx'. Jag kan hitta det där i 'rx/dist/rx.lite.js' eller till och med i 'rx/ts/rx/rx-lite.ts' som TypeScript som jag använder.
Försöker
Läs mer →typescript - Rxjs: kortform för att skapa ett observable från ett värde eller ett observable
Jag använder rxjs med TypeScript. Jag skrev följande två enkla funktioner. Men jag antar att rxjs redan har sådan funktionalitet. Har rxjs det?
export function isObservable(value: any): value is Observable<any> { return value instan Läs mer →typescript - Firebase och RxJS
Jag gjorde en funktion som lyssnar på värdehä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 ändras
Läs mer →angular - RXJS-operatörer fungerar inte med firebase
Jag använder RXJS-operatörerna med Firebase-observabeln (distinct och filter). detta är mitt Firebase-träd här. detta är min kod:
let places this.db.list(`users/${this.authProvider.getUID()}/visitedPlaces`,{ query:{ orderByChild:"googleId" } }); places.distinct((p)=>{ console.log(p) Läs mer →javascript - Typescript-modul lösning av 'rxjs' olika i samma fil
Jag har spenderat timmar med att gå runt i cirklar, så dags för en annan obskyr fråga.
Jag är inne i ett lerna mono repo, med två delprojekt, ProjectA och ProjectB.
ProjectA har ett beroende av rxjs, precis som
Läs mer →typescript - RxJS6: återställ ström efter slutförande
Jag har lekt lite med RxJS 6. Jag försöker implementera dragstart, dragmove och dragend. Detta är koden jag har hittills.
import { fromEvent } from 'rxjs'; import { concatMap } from 'rxjs/internal/operators/concatMap'; import { map } from 'rxjs/internal/operators/map'; import { takeUntil } from 'rx Läs mer →typescript - Med RxJs i Angular, behöver jag endast slutföra de Observables som skapats i komponenten?
I princip är jag fortfarande inte riktigt säker på hur rensning av reaktiv kod fungerar i Angular-komponenter. Är följande regler korrekta och tillräckliga?
Mina regler för en reaktiv komponent:
på manual x.subscribe():
- om du använder x.takeUntil(...) eller liknande konstruktion, behövs ingen manuell städning
- om x.complete() kallas i komponentens scope så behövs ingen manuell rensning
- annars manuellt .unsubscri Läs mer →
typescript - rxjs paginering med prenumeration på varje sida
Vi gör en förfrågan till graphql över websocket för att ha en prenumeration på en lista med enheter. Vi använder paginering eftersom listan förväntas kunna scrollas oändligt. Vi vill också se ändringar som görs i databasen i realtid i listan på front-end.
Denna lista kan filtreras, sorteras och paginera.
Vi har klassen SelectParams som hjälper oss att göra det:
export class SelectParams { page = 0; Läs mer →typescript - Angular 6 Fel vid användning av RxJS: Kan inte läsa egenskapen 'call' av undefined
Jag försöker migrera en Angular 5-app till Angular 6 och jag har denna ena block av RxJS-kod som förbryllar mig. Jag har Googlat och läst igenom RxJS-dokumentationen tillräckligt för att veta att jag borde använda .pipe, men jag kan inte riktigt få syntaxen rätt.
Koden returne
Läs mer →