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.
Czy jedyna różnica między Observable.ofi Observable.fromformat argumenty? Podobnie jak Function.prototype.calli Function.prototype.apply? Observable.of(1,2,3).subscribe(() => {}) Observable.from([1,2,3]).subscribe(() => {})
Znalazłem kilka implementacji, AuthGuardktóre wykorzystują take(1). W moim projekcie użyłem first(). Czy oba działają w ten sam sposób? import 'rxjs/add/operator/map'; import 'rxjs/add/operator/first'; import { Observable } from 'rxjs/Observable'; import { Injectable } from '@angular/core'; import { CanActivate, Router, ActivatedRouteSnapshot, RouterStateSnapshot } from '@angular/router'; import { AngularFire } from 'angularfire2'; @Injectable() …
Chciałbym zamknąć menu logowania, gdy użytkownik kliknie gdziekolwiek poza tym menu i chciałbym to zrobić z Angular2 i „podejściem” Angular2 ... Wdrożyłem rozwiązanie, ale naprawdę nie czuję się z nim pewnie. Myślę, że musi być najłatwiejszy sposób na osiągnięcie tego samego rezultatu, więc jeśli masz jakieś pomysły ... porozmawiajmy :)! …
Myślę, że muszę źle rozumieć coś fundamentalnego, ponieważ moim zdaniem to powinien być najbardziej podstawowy przypadek dla obserwowalnego, ale dla mojego życia nie mogę dowiedzieć się, jak to zrobić z dokumentacji. Zasadniczo chcę móc to zrobić: // create a dummy observable, which I would update manually var eventObservable = rx.Observable.create(function(observer){}); …
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 kod. Importowałem Observableza pomocą import {Observable} from 'rxjs/Observable'; Zakładam, że właściwości Observablesą również importowane ( .mapdziała). Przejrzał dziennik zmian rxjs.beta-6 i …
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? Najbardziej ceniona byłaby rzeczywista …
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ą jakieś przecięcia (coś wspólnego) między tymi dwiema technologiami, …
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 obliczeniami asynchronicznymi? A może „piekło zwrotne” …
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) { await observable; } // a bunch of other code Rozumiem, że mogę przenieść …
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}`)), catchError(this.handleError<Hero>(`getHero 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}), first() ).subscribe(x => { }) Mogę też to zrobić: …
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ę przesyłanie informacji. Szukałem czegoś podobnego finallydo Pythona , ale znalazłem tylko to, finallyco …
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ż użyć w usłudze. Ale czy jest to dobra praktyka i jedyny sposób, …
Używamy plików cookie i innych technologii śledzenia w celu poprawy komfortu przeglądania naszej witryny, aby wyświetlać spersonalizowane treści i ukierunkowane reklamy, analizować ruch w naszej witrynie, i zrozumieć, skąd pochodzą nasi goście.
Kontynuując, wyrażasz zgodę na korzystanie z plików cookie i innych technologii śledzenia oraz potwierdzasz, że masz co najmniej 16 lat lub zgodę rodzica lub opiekuna.