Suchergebnisse für Anfrage "rxjs"
wie man mehrere Abonnenten in Winkel 2 abmeldet
Ich habe shareService und abonniere das in einer anderen Komponente: import { Component, Input, OnDestroy } from '@angular/core'; import { MissionService } from './mission.service'; import { Subscription } from 'rxjs/Subscription'; @Component({ ...
Chaining Observables in RxJS
Ich lerne RxJS und Angular 2. Nehmen wir an, ich habe eine Versprechenskette mit mehreren asynchronen Funktionsaufrufen, die vom Ergebnis des vorherigen abhängen und wie folgt aussehen: var promiseChain = new Promise((resolve, reject) => { ...
Wie binde ich meinen eigenen RxJS-Betreff in beide Richtungen an ein [(ngModel)]?
ibt es eine kurze und einfache Möglichkeit, einen RxJS zu übergebeSubject [http://reactivex.io/rxjs/class/es6/Subject.js~Subject.html] oderBehaviorSubject [http://reactivex.io/rxjs/class/es6/BehaviorSubject.js~BehaviorSubject.html] zu einer ...
BehaviorSubject vs Observable?
Ich untersuche Angular RxJs-Muster und verstehe den Unterschied zwischen a @ nichBehaviorSubject und einObservable. ach meinem Verständnis ist einBehaviorSubject ist ein Wert, der sich im Laufe der Zeit ändern kann (abonniert werden kann und ...
Wie erhalte ich Blob-Antworten mit dem Angular 2+ @ angle / http-Modul?
Ich versuche, einen PDF-Download in einer eckigen 2-App bereitzustellen ... dieser Code funktioniert: var reportPost = 'variable=lsdkjf'; var xhr = new XMLHttpRequest(); xhr.open("POST", "http://localhost/a2/pdf.php", true); xhr.responseType ...
Angular 2s HTTP-Dienst macht map () und andere RxJS-Funktionen nicht verfügbar
Weiß jemand, ob Änderungen am http zwischen Alpha 45 und Alpha 48 vorgenommen wurden? Ich habe gesucht und nichts gefunden. Mein Problem ist, dass der folgende Code perfekt auf Alpha 45 funktioniert hat. Aber jetzt, wo ich auf Alpha 48 ...
rxjs Observable wird nicht abgeschlossen, wenn ein Fehler auftritt
Wenn ich ein Observable von Grund auf neu erstelle und den Observer-Fehler beende, wird der erledigte Teil des Abonnements nie aufgerufen. var observer = Rx.Observable.create(function(observer){ observer.onError(new Error('no!')); ...
Abonnieren einer verschachtelten Observable
Ich habe eine App, die eine http-Anforderung zum Abrufen einer Liste von Elementen und anschließend eine http-Anforderung für jedes Element in der Liste erstellt, um detailliertere Informationen zu jedem Element abzurufen. Effektiv class ...
Warum müssen wir flatMap verwenden?
Ich beginne RxJS zu verwenden und verstehe nicht, warum wir in diesem Beispiel eine Funktion wie @ verwenden müsseflatMap oderconcatAll; Wo ist das Array von Arrays hier? var requestStream = Rx.Observable.just('https://api.github.com/users'); ...
behaviourSubject in angle2, wie es funktioniert und wie man es benutzt
Ich versuche, einen gemeinsamen Dienst wie folgt zu erstellen: import {Injectable,EventEmitter} from 'angular2/core'; import {Subject} from 'rxjs/Subject'; import {BehaviorSubject} from 'rxjs/subject/BehaviorSubject'; @Injectable() export class ...