Na stronie dokumentacji Angular 2 dotyczącej korzystania z usługi HTTP znajduje się przykład. getHeroes (): Observable<Stuff[]> { return this.http.get(this.url) .map(this.extractData) .catch(this.handleError); } Sklonowałem projekt angular2-webpack-starter i sam dodałem powyższy...
Chciałem zrozumieć te 3: Temat , temat zachowania i temat powtórki . Chciałbym ich używać i wiedzieć, kiedy i dlaczego, jakie są korzyści z ich używania i chociaż przeczytałem dokumentację, obejrzałem tutoriale i przeszukałem google, nie udało mi się tego zrozumieć. Więc jaki jest ich cel?...
Mam usługę, która ma tę metodę: export class TestModelService { public testModel: TestModel; constructor( @Inject(Http) public http: Http) { } public fetchModel(uuid: string = undefined): Observable<string> { if(!uuid) { //return Observable of JSON.stringify(new TestModel()); }...
Czy ktoś może podać jasną definicję wraz z prostym przykładem wyjaśniającym, czym jest „piekło zwrotne” dla kogoś, kto nie zna JavaScript i node.js? Kiedy (w jakich ustawieniach) pojawia się „problem z piekłem zwrotnym”? Dlaczego tak się dzieje? Czy „piekło zwrotne” jest zawsze związane z...
Wiem, że Redux jest lepszą "implementacją" Fluxa, albo lepiej mówiąc, że jest to przeprojektowanie mające na celu uproszczenie rzeczy (zarządzanie stanem aplikacji). Wiele słyszałem o programowaniu reaktywnym (RxJS), ale jeszcze nie nurkowałem, aby się go nauczyć. Więc moje pytanie brzmi: czy są...
Chciałbym móc czekać na obserwowalny, np const source = Rx.Observable.create(/* ... */) //... await source; Naiwna próba skutkuje natychmiastowym rozstrzygnięciem oczekiwania i nie blokowaniem wykonania Edycja: pseudokod dla mojego pełnego zamierzonego przypadku użycia to: if (condition) {...
Rury to filtry służące do przekształcania danych (formatów) w szablonie. Natrafiłem na pipe()funkcję jak poniżej. Co pipe()dokładnie oznacza ta funkcja w tym przypadku? return this.http.get<Hero>(url) .pipe( tap(_ => this.log(`fetched hero id=${id}`)),
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ę...
W aplikacji kątowej mamy ngOnDestroy()hak cyklu życia dla komponentu / dyrektywy i używamy tego haka do anulowania subskrypcji obserwabli. Chcę wyczyścić / zniszczyć obserwowalne, które są tworzone w @injectable()usłudze. Widziałem posty, w których napisano, że ngOnDestroy()można ich również...
Kiedy uruchamiam linter, mówi: subscribe is deprecated: Use an observer instead of an error callback Kod (z aplikacji angular 7 z angular-cli): this.userService.updateUser(data).pipe( tap(() => {bla bla bla}) ).subscribe( this.handleUpdateResponse.bind(this),
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) => {...
Obecnie próbuję nauczyć się Angular2 i TypeScript po szczęśliwej pracy z AngularJS 1. * przez ostatnie 4 lata! Muszę przyznać, że go nienawidzę, ale jestem pewien, że mój moment eureki jest tuż za rogiem ... w każdym razie napisałem usługę w mojej fałszywej aplikacji, która pobierze dane http z...
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) {...
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...
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
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...
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...
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ę?
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...