Korzystając z protokołu HTTP, wywołujemy metodę, która wykonuje połączenie sieciowe i zwraca obserwowalny http: getCustomer() { return this.http.get('/someUrl').map(res => res.json()); } Jeśli weźmiemy to pod uwagę i dodamy do niej wielu subskrybentów: let network$ = getCustomer(); let...
Myślę, że mam podstawową koncepcję, ale są pewne niejasności Tak więc ogólnie używam Observable: observable.subscribe(x => { }) Jeśli chcę filtrować dane, mogę użyć tego: import { first, last, map, reduce, find, skipWhile } from 'rxjs/operators'; observable.pipe( map(x => {return x}),...
Zgodnie z tym artykułem , onCompletea onErrorfunkcje tych elementów subscribewzajemnie się wykluczają. Czyli albo onErrorczy onCompleteimprezy będzie ogień w moim subscribe. Mam blok logiczny, który musi zostać wykonany, niezależnie od tego, czy otrzymam błąd, czy pomyślnie zakończę...
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) => {...
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ę?
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.