Questions marquées «rxjs»

Quelle est la différence entre PromiseetObservable dans Angular? Un exemple sur chacun serait utile pour comprendre les deux cas. Dans quel scénario pouvons-nous utiliser chaque

Quand dois-je stocker les Subscriptioninstances et les invoquer unsubscribe()pendant le cycle de vie NgOnDestroy et quand puis-je simplement les ignorer? L'enregistrement de tous les abonnements introduit beaucoup de désordre dans le code des composants. Le Guide du client HTTP ignore les...

J'examine les motifs angulaires RxJs et je ne comprends pas la différence entre a BehaviorSubjectet an Observable. D'après ma compréhension, a BehaviorSubjectest une valeur qui peut changer au fil du temps (peut être abonné et les abonnés peuvent recevoir des résultats mis à jour). Cela semble être...

J'ai un problème avec HTTP dans Angular. Je veux juste GETune JSONliste et la montrer dans la vue. Classe de service import {Injectable} from "angular2/core"; import {Hall} from "./hall"; import {Http} from "angular2/http"; @Injectable() export class HallService { public http:Http; public static...

En utilisant Http, nous appelons une méthode qui effectue un appel réseau et renvoie un http observable: getCustomer() { return this.http.get('/someUrl').map(res => res.json()); } Si nous prenons cela observable et y ajoutons plusieurs abonnés: let network$ = getCustomer(); let subscriber1 =...

Je ne suis pas clair sur la différence entre a Subjectet a BehaviorSubject. Est-ce juste que a BehaviorSubjecta la

J'essaie d'enrouler ma tête autour d'observables. J'aime la façon dont les observables résolvent les problèmes de développement et de lisibilité. Comme je l'ai lu, les avantages sont immenses. Les observables sur HTTP et les collections semblent être simples. Comment puis-je convertir quelque chose...

Devez-vous vous désabonner des appels http Angular 2 pour éviter les fuites de mémoire? fetchFilm(index) { var sub = this._http.get(`http://example.com`) .map(result => result.json()) .map(json => { dispatch(this.receiveFilm(json)); }) .subscribe(e=>sub.unsubscribe()); ......

J'ai un service Angular 2: import {Storage} from './storage'; import {Injectable} from 'angular2/core'; import {Subject} from 'rxjs/Subject'; @Injectable() export class SessionStorage extends Storage { private _isLoggedInSource = new Subject<boolean>(); isLoggedIn =

J'ai un problème avec la Observable.offonction d' importation dans mon projet. Mon Intellij voit tout. Dans mon code j'ai: import {Observable} from 'rxjs/Observable'; et dans mon code je l'utilise comme ça: return Observable.of(res); Des idées?

Je viens de passer d'Angular 2 beta16 à beta17 , qui à son tour nécessite rxjs 5.0.0-beta.6. (Changelog ici: https://github.com/angular/angular/blob/master/CHANGELOG.md#200-beta17-2016-04-28 ) En beta16 tout fonctionnait bien en ce qui concerne la fonctionnalité Observable / map. Les erreurs...

Je dois créer un abonnement à un Observablequi est immédiatement supprimé lors de son premier appel. Y a-t-il quelque chose comme: observable.subscribeOnce(func); Mon cas d'utilisation, je crée un abonnement dans un gestionnaire d'itinéraire express et l'abonnement est appelé plusieurs fois par...

Maintenant, j'ai une page initiale où j'ai trois liens. Une fois que vous cliquez sur le dernier lien «amis», le composant amis approprié est lancé. Là-dedans, je veux récupérer / obtenir la liste de mes amis dans le fichier friends.json. Jusqu'à présent, tout fonctionne bien. Mais je suis toujours...

La fonction more()est censée renvoyer un à Observablepartir d'une requête get export class Collection{ public more = (): Observable<Response> => { if (this.hasMore()) { return this.fetch(); } else{ // return empty observable } } private fetch = (): Observable<Response> => { return...

Code dactylographié: import { Injectable } from '@angular/core'; import { Observable } from 'rxjs/Observable'; import { of } from 'rxjs/observable/of'; import { Hero } from './hero'; import { HEROES } from './mock-heroes'; @Injectable({ providedIn: 'root' }) export class HeroService {...

La seule différence entre Observable.ofet Observable.fromle format des arguments? Comme le Function.prototype.callet Function.prototype.apply? Observable.of(1,2,3).subscribe(() => {}) Observable.from([1,2,3]).subscribe(() => {})

Je voudrais fermer ma liste déroulante de menu de connexion lorsque l'utilisateur clique n'importe où en dehors de cette liste déroulante, et j'aimerais le faire avec Angular2 et avec "l'approche" Angular2 ... J'ai mis en place une solution, mais je ne me sens vraiment pas en confiance. Je pense...

J'ai une erreur de node_modules / rxjs / internal / types.d.ts (81,44): erreur TS1005: ';' attendu. après l'installation d'Angular 6. Vérifiez l'erreur: ERROR in node_modules/rxjs/internal/types.d.ts(81,44): error TS1005: ';' expected. node_modules/rxjs/internal/types.d.ts(81,74): error TS1005: ';'...

Je pense que je dois mal comprendre quelque chose de fondamental, car dans mon esprit, cela devrait être le cas le plus élémentaire pour un observable, mais pour la vie de mon, je ne peux pas comprendre comment le faire à partir de la documentation. Fondamentalement, je veux pouvoir faire ceci: //...

J'ai trouvé quelques implémentations de AuthGuards qui utilisent take(1). Dans mon projet, j'ai utilisé first(). Les deux fonctionnent-ils de la même manière? import 'rxjs/add/operator/map'; import 'rxjs/add/operator/first'; import { Observable } from 'rxjs/Observable'; import { Injectable } from...