Articles of rxjs

Rxjs: Observable.combineLatest vs Observable.forkJoin

Je me demande simplement quelles sont les différences entre Observable.combineLatest et Observable.forkJoin ? Pour autant que je forkJoin , la seule différence est que forkJoin s’attend à ce que les observables soient terminés, tandis que combineLatest renvoie les dernières valeurs.

Comment puis-je contourner l’erreur «Sujet incorrectement étendu Observable» dans TypeScript 2.4 et RxJS 5.x?

Lorsque je comstack, j’obtiens l’erreur de compilation suivante dans les fichiers de déclaration RxJS: node_modules/rxjs/Subject.d.ts(16,22): error TS2415: Class ‘Subject’ incorrectly extends base class ‘Observable’. Types of property ‘lift’ are incompatible. Type ‘(operator: Operator) => Observable’ is not assignable to type ‘(operator: Operator) => Observable’. Type ‘Observable’ is not assignable to type ‘Observable’. Type ‘T’ is […]

Quelle est la différence entre les abonnements Rx.Observable et forEach

Après avoir créé un observable comme ça var source = Rx.Observable.create(function(observer) {…}); Quelle est la différence entre s’abonner source.subscribe(function(x) {}); et pour chaque source.forEach(function(x) {});

Opérateur RxJs pipe et lettable `map`: ‘ce’ contexte de type ‘void’ n’est pas assignable à la méthode ‘this’ de type ‘Observable ‘

J’ai cet exemple très basique qui utilise une map opérateur louable avec un pipe de rxjs@5.5 : import { map } from ‘rxjs/operator/map’; let o = of(1, 2, 3, 4).pipe( map((v) => v * 2) ); Mais il produit l’erreur Error:(34, 5) TS2684:The ‘this’ context of type ‘void’ is not assignable to method’s ‘this’ of […]

Gestion des jetons d’actualisation à l’aide de rxjs

Depuis que j’ai commencé avec angular2, j’ai configuré mes services pour retourner Observable de T. Dans le service, l’appel à map () et les composants utilisant ces services utiliseraient simplement subscribe () pour attendre la réponse. Pour ces scénarios simples, je n’avais pas vraiment besoin de me concentrer sur RXJS, donc tout allait bien. Je […]

Meilleur moyen d’importer Observable à partir de rxjs

Dans mon application angular 2, j’ai un service qui utilise la classe Observable de la bibliothèque rxjs . import { Observable } from ‘rxjs’; En ce moment, j’utilise simplement Observable pour pouvoir utiliser la fonction toPromise() . J’ai lu dans une autre question de StackOverflow quelque part que l’importation de cette manière et l’importation de […]

SwitchMap vs MergeMap dans l’exemple #ngrx

Voici le code de l’exemple Ngrx: https://github.com/ngrx/example-app/blob/master/src/effects/book.ts Ma question est la suivante: dans le premier @Effect, il utilise switchMap alors que les autres utilisent mergeMap . Est-ce parce que le premier @Effect traite du réseau et que le switchMap vous permet d’annuler la requête réseau précédente si elle est en cours d’exécution? @Effect() search$ = […]

Quelle est la différence entre Knockout.js et Rx.js?

Est-ce que quelqu’un connaît les différences entre RxJs et Knockout ? En apparence, ils semblent essayer de résoudre le même problème, pour construire une interface utilisateur pilotée par les événements. Mais quelqu’un qui a de l’expérience avec les deux, comment diffèrent-ils / comment sont-ils similaires? Pouvez-vous décrire quelque chose à leur sujet pour m’aider à […]

Comment renvoyer la valeur de la fonction qui a un abonnement Observable à l’intérieur?

Je ne sais pas comment extraire la valeur de Observable pour être retourné par la fonction dans laquelle Observable est présent. Je n’ai besoin que d’une valeur pour être retourné, rien d’autre. Version actuelle qui fonctionne function getValueFromObservable() { this.store.subscribe( (data:any) => { console.log(data) } ) } getValueFromObservable() J’ai besoin de cela pour fonctionner, fonction […]

TypeError: search.valueChanges.debounceTime n’est pas une fonction

Je ne fais qu’apprendre angular2. Au moment d’appliquer quelque chose aux changements d’entrée, je reçois l’erreur. app.ts: export class AppComponent { form: ControlGroup; constructor(fb: FormBuilder) { this.form = fb.group({ search: [] }); var search = this.form.find(‘search’); search.valueChanges .debounceTime(400) .map(str => (str).replace(‘ ‘,’‐’)) .subscribe(x => console.log(x)); }; } Erreur: Comment résoudre ce problème? Est-ce que je […]