Pytania otagowane jako rxjs

Reactive Extensions for JavaScript (RxJS) to zestaw bibliotek do tworzenia programów asynchronicznych i opartych na zdarzeniach przy użyciu obserwowalnych kolekcji i kompozycji w stylu Array Extras.

10
Jak zwrócić wartość z funkcji, która ma wewnątrz subskrypcję Observable?
Nie wiem, jak wyodrębnić wartość z Observable, aby została zwrócona przez funkcję, w której obecny jest Observable. Potrzebuję tylko wartości z tego, aby została zwrócona, nic więcej. Aktualna wersja, która działa function getValueFromObservable() { this.store.subscribe( (data:any) => { console.log(data) } ) } getValueFromObservable() Potrzebuję tego do działania, funkcji do zwracania …
10
Dlaczego musimy używać flatMap?
Zaczynam używać RxJS i nie rozumiem, dlaczego w tym przykładzie musimy użyć funkcji takiej jak flatMaplub concatAll; gdzie jest tablica tablic? var requestStream = Rx.Observable.just('https://api.github.com/users'); var responseMetastream = requestStream .flatMap(function(requestUrl) { return Rx.Observable.fromPromise(jQuery.getJSON(requestUrl)); }); responseMetastream.subscribe(url => {console.log(url)}) Jeśli ktoś może wizualnie wyjaśnić, co się dzieje, będzie to bardzo pomocne.
95 javascript  rxjs 
4
Używanie tablicy z obiektu obserwowalnego z ngFor i Async Pipe Angular 2
Próbuję zrozumieć, jak używać Observables w Angular 2. Mam tę usługę: import {Injectable, EventEmitter, ViewChild} from '@angular/core'; import {Observable} from "rxjs/Observable"; import {Subject} from "rxjs/Subject"; import {BehaviorSubject} from "rxjs/Rx"; import {Availabilities} from './availabilities-interface' @Injectable() export class AppointmentChoiceStore { public _appointmentChoices: BehaviorSubject<Availabilities> = new BehaviorSubject<Availabilities>({"availabilities": [''], "length": 0}) constructor() {} getAppointments() …
3
Jak zgłosić błąd z operatora mapy RxJS (kątowy)
Chcę zgłosić błąd z operatora mapy mojego obserwowalnego na podstawie warunku. Na przykład, jeśli nie otrzymano poprawnych danych API. Zobacz poniższy kod: private userAuthenticate( email: string, password: string ) { return this.httpPost(`${this.baseApiUrl}/auth?format=json&provider=login`, {userName: email, password: password}) .map( res => { if ( res.bearerToken ) { return this.saveJwt(res.bearerToken); } else { …
4
Promise.all zachowanie z RxJS Observables?
W Angular 1.x czasami musiałem składać wiele httpżądań i robić coś ze wszystkimi odpowiedziami. Wrzuciłbym wszystkie obietnice do tablicy i zadzwonił Promise.all(promises).then(function (results) {...}). Najlepsze praktyki Angular 2 wydają się wskazywać na użycie RxJS Observablejako zamiennika obietnic w httpżądaniach. Jeśli mam dwa lub więcej różnych Observables utworzonych na podstawie żądań …
19
Błąd rxjs / Subject.d.ts: Klasa „Subject <T>” niepoprawnie rozszerza klasę bazową „Observable <T>”
Wyodrębniłem przykładowy kod szablonu z tego samouczka i wykonałem poniżej dwa kroki, aby rozpocząć - npm install // worked fine and created node_modules folder with all dependencies npm start // nie powiodło się z poniższym błędem- node_modules/rxjs/Subject.d.ts(16,22): error TS2415: Class 'Subject&lt;T&gt;' incorrectly extends base class 'Observable&lt;T&gt;'. Types of property 'lift' …
2
Kiedy używać asObservable () w rxjs?
Zastanawiam się, jaki jest pożytek z asObservable: Zgodnie z dokumentami: Obserwowalna sekwencja, która ukrywa tożsamość sekwencji źródłowej. Ale dlaczego miałbyś ukrywać sekwencję?
88 rxjs  rxjs5 
10
Jak sprawić, by jedna obserwowalna sekwencja czekała na zakończenie innej przed wyemitowaniem?
Powiedz, że mam Observabletak: var one = someObservable.take(1); one.subscribe(function(){ /* do something */ }); Następnie mam sekundę Observable: var two = someOtherObservable.take(1); Teraz chcę subscribe()się two, ale chcę, aby upewnić się, że onezostał zakończony przed twoabonent zostaje zwolniony. Jakiej metody buforowania mogę użyć, twoaby druga z nich czekała na zakończenie …
3
Rxjs: Observable.combineLatest vs Observable.forkJoin
Zastanawiam się tylko, jakie są różnice między Observable.combineLatesti Observable.forkJoin? O ile widzę, jedyną różnicą jest to, forkJoinże oczekuje się, że Observables zostaną zakończone, a combineLatestzwrócą najnowsze wartości.
86 rxjs  rxjs5 
10
Żądania ponownej próby Angular 4 Interceptor po odświeżeniu tokenu
Cześć, próbuję dowiedzieć się, jak zaimplementować nowe kątowe przechwytywacze i obsłużyć 401 unauthorizedbłędy, odświeżając token i ponawiając żądanie. Oto przewodnik, który śledziłem: https://ryanchenkie.com/angular-authentication-using-the-http-client-and-http-interceptors Pomyślnie buforuję żądania, które nie powiodły się, i mogę odświeżyć token, ale nie mogę dowiedzieć się, jak ponownie wysłać żądania, które wcześniej zakończyły się niepowodzeniem. Chcę również, …
8
Sekwencja RxJS równoważna obietnicy.then ()?
Kiedyś dużo się rozwijałem z obietnicą, a teraz przechodzę do RxJS. Dokumentacja RxJS nie dostarcza jasnego przykładu, jak przejść od łańcucha obietnic do sekwencji obserwatorów. Na przykład zazwyczaj piszę łańcuch obietnic z wieloma krokami, jak np // a function that returns a promise getPromise() .then(function(result) { // do something }) …
84 javascript  rxjs 
4
Dziecko nasłuchuje zdarzenia rodzica w Angular 2
W Angular Docs jest temat słuchania dziecięcych wydarzeń od rodziców. W porządku. Ale moim celem jest coś odwrotnego !. W mojej aplikacji jest „admin.component”, który przechowuje widok układu strony administratora (menu paska bocznego, pasek zadań, status itp.). W tym komponencie nadrzędnym skonfigurowałem system routerów do zmiany widoku głównego między innymi …
9
Jak anulować subskrypcję w Angular2
Jak anulować subskrypcję w Angular2? Wydaje się, że RxJS ma metodę usuwania, ale nie mogę dowiedzieć się, jak uzyskać do niej dostęp. Mam więc kod, który ma dostęp do EventEmittera i subskrybuje go, na przykład: var mySubscription = someEventEmitter.subscribe( (val) =&gt; { console.log('Received:', val); }, (err) =&gt; { console.log('Received error:', …
Korzystając z naszej strony potwierdzasz, że przeczytałeś(-aś) i rozumiesz nasze zasady używania plików cookie i zasady ochrony prywatności.
Licensed under cc by-sa 3.0 with attribution required.