angular - Hur kan jag utöka RxJS?
Jag letar efter ett sätt att köra en återuppringning när någon anropar subscribe på en instans av en given klass som implementerar Observable.
I avsaknad av en hook i RxJS-biblioteket, skulle jag i nästan vilket annat objektorienterat språk som helst:
- ärva klassen jag vill anpassa (ReplaySubject i detta fall);
- skriv över subscribe-metoden; och
- utför min återuppringning och delegera sedan anropet till superkla Läs mer →
javascript - Hur man dynamiskt kedjar funktionsanrop med RXJS?
Jag behöver cacha resultatet av en förfrågan vid det första anropet och sedan läsa det cachade värdet vid efterföljande anrop.
För att uppnå det målet använder jag löften och jag kedjar dem. Jag har en fungerande lösning men jag skulle vilja konvertera den till RxJS-observabler istället för löften.
H
Läs mer →typescript - Angular 2 RC4 RxJS Krasch
Jag har en kodbit som fungerade perfekt tills den senaste Angular 2-uppdateringen. Bland annat använder den Http-förfrågningar och Observables.
Jag uppdaterade till RC4, importerade alla RxJS-operatörer (för att vara säker på att det fungerar) och jag får Fel: SecurityError: DOM Exception 18
Har du någon aning om varför och hur jag kan fixa detta?
Förenklad kodsnutt:
logIn(email: string, pass: string): Observable<boolean> { return Observable.create((obs Läs mer →typescript - Dynamiskt filtrera rxjs-ström
Jag använder RXJS och jag försöker filtrera datan dynamiskt, men jag har problem:
let numberSource: ReplaySubject<Number> = new ReplaySubject<Number>(); let numberFilter: BehaviorSubject<Number> = new BehaviorSubject<Number>(5); let filteredData = numberSource.filter(n => n < numberFilter.value); numb Läs mer →typescript - rxjs5: Fördröj avprenumeration av ett delat observerbart
Jag har ett observabelt som är dyrt att skapa, så jag har shared det. I vissa fall avregistrerar sig dock alla prenumeranter och sedan prenumererar en ny prenumerant genast (eller efter en kort fördröjning).
Det faktiska observerbara är för komplext för att återskapas här, men för argumentets sk
Läs mer →angular - RxJs-operatörer som orsakar TypeScript-fel
Arbetsversion:
const observable = Observable .from([Promise.resolve('1'), Promise.resolve('2')]) .subscribe((results) => {})Trasig version (lade till mergeAll-operatör):
const observable = Observable .from([Promise.resolv Läs mer →angular - Skicka API-förfrågan vid en given tidpunkt för att uppdatera aktuell radioprogram Angular2 RxJS
Jag arbetar på ett schema för en communityradiostation och undrar hur jag kan gå tillväga för att uppdatera det aktuella programmet som spelas.
Jag har kommit så långt som att fråga servern en gång i minuten (inte säker på att det är rätt sätt att göra det
Läs mer →Hur man enhetstestar rxjs debounceTime-logik (Angular)?
Med min brist på kunskap om RxJs kopierade jag->klistrade in lite kod som använde det, modifierade den och nu misslyckas jag med att testa den...
Här är hela komponenten:
import { Component } from '@angular/core'; import { Observable } from 'rxjs/Observable'; import { map } from 'rxjs/operator/ma Läs mer →javascript - prenumerera om villkoret uppfylls annars returnera/avsluta rxjs
Hur kan jag kontrollera tillståndet innan det prenumererar inom operatörskedjan? Jag har något liknande detta.
parentElem:boolean = false; // the parent elem show/hide; // inside the ngAfterViewInit(); this.myForm.get('grandParent').valueChanges //.takeWhile(...) no idea if it works with Läs mer →typescript - Hur fångar jag ett fel på två olika punkter i RxJS/Angular?
Anta detta Angular 2-utdrag:
export class ApiService { // do stuff request(...): Observable<Response> { return this.http.request(...) .share() .catch((error: any) => { let errMsg = 'my error'; // do more stuff... // trie Läs mer →