Tag: rxjs
Die Reactive Extensions für die JavaScript (RxJS) ist ein Satz von Bibliotheken für das erstellen von asynchronen und event-basierten Programmen mit observable collections und Array-Extras-Stil-Komposition.
RxJS: concat drei Verheißungen unterscheiden, die Ergebnisse
2 Antworten
Habe ich drei zusagen, Rest-Anfragen zurückgeben von Listen von Daten. Das Dritte ist mit Referenzen (ids) zu den ersten beiden Listen, so will ich anzeigen diese ids auf die entsprechenden Namen, wenn ich alle Daten haben. Das
Synchronität in RxJS
1 Antworten
Ich würde erwarten, dass der folgende code asynchron ausführen: var range = Rx.Observable.range(0, 3000000); range.subscribe( function(x) {}, function(err) {}, function() { console.log('Completed'); }); console.log('Hello World'); Aber das ist nicht der Fall. Es dauert eine Weile, um durch
RxJs: poll, bis Intervall gemacht oder korrekten Daten empfangen
3 Antworten
Wie führe ich das folgende Szenario im browser mit RxJs: übermitteln von Daten in der Warteschlange für die Verarbeitung wieder die job-id poll anderen Endpunkt alle 1s, bis das Ergebnis verfügbar ist oder 60 Sekunden vergangen sind(dann
Angular2 rxjs - switchmap fangen Fehler
1 Antworten
Ich würde gerne in der Lage sein zu handhaben, Fehler, Fehler beim Aufruf von this.authService.refreshToken(). Können Fehler behandelt werden, die innerhalb der switchmap block, oder wie gehe ich über den Umgang mit einem Fehler in diesem Fall?
RxJS: JSON-Daten mit einem array, die Verarbeitung jedes Element weiter in den stream
2 Antworten
Bekomme ich eine HTTP-Antwort, die enthält, wenn alles gut geht, ein einzelnes array, codiert als JSON. Ich will diesen array, herauszufiltern, einige Elemente und Prozess der Weitergabe Elemente als Ereignisse. Was ich tun so weit ist: return
Wie push-to-Observable-Array in Eckigen 4? RxJS
3 Antworten
Habe ich eine Immobilie auf meine service-Klasse als so: articles: Observable<Article>; Es ist bevölkert von einer getArticles () - Funktion mit der standard - http.get().map() Lösung. Wie kann ich manuell schieben Sie einen neuen Artikel in diesem
RxJS emittieren array-Elemente über die Zeit?
7 Antworten
Ich versuche zu emittieren einfache array Werte einer nach dem anderen mit 500ms dazwischen: var a = Rx.Observable.from([1,2,3]); a.interval(500).subscribe(function(b) { console.log(b); }); Aber dies wirft eine Ausnahme: Uncaught TypeError: a.interval is not a function. mehr prägnante Antworten
Winkel 2 rxjs timeout callback
1 Antworten
Will ich geben von feedback an den Benutzer, wenn ein timeout-Ereignis auf einem HTTP-Aufruf passiert. Habe ich versucht, dieses: return this._http .post(apiUrl + 'Search/Everything', params, {withCredentials: true, headers: this.headers}) .timeout(5000, this._feedbackService.error("Custom error message")) .map((response: Response) => response.json().data);
mergeMap existiert nicht auf beobachtbaren Typ
4 Antworten
Ich versuche, mit mergeMap im rxjs6 und ich bin immer diese Fehlermeldung: Property 'mergeMap' does not exist on type 'Observable<{}>' Habe ich versucht import 'rxjs/add/operator/mergeMap'; und es funktioniert nicht. Was mache ich falsch? import {from, Observable} from
Angular 2.0 - konvertieren von Versprechen, die die Verkettung mit physikalischen Grössen
2 Antworten
Bin ich mit der Konvertierung eines NG-1.X service-NG 2.0. Mein NG 1.X service hat Versprechen chaining (vereinfacht): dataService.search = function(searchExp) { return this.getAccessToken() .then(function(accesstoken) { var url = $interpolate('https://my-api-url?q={{search}}&{{accesstoken}}')({search: searchExp, accesstoken: accesstoken}); return $http({ url: url, method:
Typoskript/Winkel try catch ein Fehler im try-block nicht catch-block
1 Antworten
Ich bin mit Winkel-und Maschinenschrift. Ich habe verwendet, versuchen Sie, catch-Konstrukt zur Fehlerbehandlung im Falle von API-Aufruf. Wenn irgendwelche Fehler tritt im try-block es ist einfach NICHT catch-block. App beendet sich es nur. Habe ich versucht, mit
rxjs 6 Eigentums "' existiert nicht auf Typ 'typeof Beobachtbaren'
1 Antworten
Nur verschoben von rxjs 5/Winkel 5 zu rxjs 6/Winkel-6, ging durch diese migration-guide. Kann nicht scheinen, um herauszufinden, was es sein sollte nun, jede Hilfe zu schätzen. import { Observable, of } from 'rxjs'; [ts] 'of' is
'erwarten' Ausdruck ist nur zulässig innerhalb einer asynchronen Funktion
1 Antworten
Ich habe eine async-Methode wie unten. Es zeigt einen Fehler [ts] 'await' expression is only allowed within an async function. hier await userProfile.set({. Können Sie mir sagen, wie zu Sortieren, es? Hinweis: Vielleicht ist es wegen habe
Jasmin Unit-test - Nicht Lesen-Eigenschaft pipe undefined
1 Antworten
Ich bin mit Winkel-6, NgRx 6, RxJS 6. Habe ich eine route Wächter, der sah aus wie dieser - import { CanActivate, ActivatedRouteSnapshot } from '@angular/router'; import { Injectable } from '@angular/core'; import { Observable, of }
Winkel-Service mit dem Betreff Beobachtbaren Aufruf von next() ist nicht ersichtlich Komponente Abonnements
2 Antworten
Möchte ich abrufen einer aktualisierten Objekt-Wert (Kreditnehmer) von schräg-Dienst. Ich habe eine RxJS Subject im Dienst, so dass mehrere Komponenten können ihn abonnieren und erhalten Sie den aktualisierten Wert. Wenn ich lese das Thema durch die erbrachte
Eckige 4 - canActivate beobachtbaren nicht aufgerufen werden
3 Antworten
Bin ich versucht zu implementieren canActivate im Winkel 2/4 mit RxJS observablen. Ich habe schon gelesen eine andere Frage auf dieser. Mit dem folgenden code, der meine canActivate Methode funktioniert nur einmal, wenn die app startet, aber
Winkel 6 http.löschen funktioniert nicht
2 Antworten
Ich kann nicht scheinen, um meine Anfrage löschen zu arbeiten. Ich habe fertig, alle Anfragen bekommen, aber jetzt bin ich stecken Sie auf löschen, und kann nicht scheinen, um wickeln Sie meinen Kopf herum. Die Konsole.log würd
Winkel 4. Eine Reihe von http-Anfragen storniert
3 Antworten
Wenn ich versuche, mehrere http-requests über http-service im Winkel 4, bisherige Antrag storniert in Chrome (aber Sie erreichen den server). Beispiel: const obs1 = this.http.get(`${API_URL}/transitions`); const obs2 = this.http.get(`${API_URL}/states`); obs1.subscribe(); obs2.subscribe(); //this will cancel obs1's http request
Wie zu beobachten-Objekt ändert sich mit rxjs 5
3 Antworten
Ich würde gerne zusehen, wie über ein Objekt, so werden alle Abonnenten darüber informiert werden änderungen es. Sah ich es schon vor der Frage, doch die Antwort ist irrelevant, da RXjs Version 5 beinhalten nicht die ofObjectChanges
Angular2: Dynamische synchrone http-requests
3 Antworten
Ziel: eine Reihe von synchronen http-Anfragen und in der Lage sein, zu abonnieren, um Sie als eine wahrnehmbare stream. Beispiel (Funktioniert Nicht): let query_arr = ['test1','test2','test3'] function make_request(query_arr){ if (query_arr.length){ let payload = JSON.stringify(query_arr[0]); let headers =
Wie zu fangen Fehler in RxJS 5.5
3 Antworten
Ich bin mit Angular 5 zusammen mit RXJS 5.5 Vorher konnte ich nur so etwas tun getProjectInfo(id): Observable<any> { const URL = `${this.API}/${id}`; return this.http.get(URL) .pipe(map(res => res)), catchError(this.handleServerError); } handleServerError(error: any) { console.log(error.error || error.json() ||
Error: Cannot find module "rxjs/Betreiber" in Ionic Angular
1 Antworten
Ich versuche mein Ionic-Projekt. Es funktionierte gut, bis vor einigen Tagen, jetzt kann ich gerade nicht ausführen, was ich Tue. dieser Fehler wird angezeigt! Ich habe versucht, das entfernen Rxjs aus der Verpackung.json und node_modules, kommentierte auch
Null/leer, erkennbar im Winkel 6 mit Rxjs 6
4 Antworten
Arbeite ich an Winkel 6 mit Rxjs 6 zwar habe ich eine Frage bezüglich der Rückgabe einer null/leer ist Beobachtbar, wenn die Antwort nicht oder ist Ausnahme, Hier ist meine Annahme, mein remote-api wird ein Objekt zurückgeben,
Kann set property stack von [object object] der hat nur einen getter
1 Antworten
Ich erhalte die folgende Fehlermeldung in der folgenden plunker. Kann set property stack von [object object] die hat nur eine get - Plunker ist hier https://plnkr.co/edit/IP1ssat2Gpu1Cra495u2?p=preview Code ist wie folgt: //our root app component import {Component, NgModule,
Wie leicht zu konvertieren oder zuweisen eine Beobachtbare Verhaltensweise Unterliegen, so dass andere Komponenten können teilen Sie es
2 Antworten
Ich bin neu auf Beobachtbaren Stil Programmierung. Ich habe eine Frage: ich möchte über Benutzer-info in der app zwischen den Komponenten - - - und ich benutze BehaviorSubject teilen dieser info. Dies ist inspiriert durch den Austausch
Warum sollten wir nutzen, RxJs von () - Funktion?
3 Antworten
im service-Bereich unregelmäßig.io-tutorial für angular2 ich traf eine Methode mit dem Namen der.zum Beispiel : getHeroes(): Observable<Hero> { return of(HEROES); } oder im folgenden Beispiel: getHero(id: number): Observable<Hero> { //Todo: send the message _after_ fetching the hero
Eckig/RxJS 6: Wie verhindern, dass doppelte HTTP-requests?
4 Antworten
Haben derzeit ein Szenario, in dem eine Methode in einer shared-service-verwendet wird, durch mehrere Komponenten. Dieses Verfahren macht eine HTTP-Aufruf an einen Endpunkt haben stets die gleiche Antwort und gibt es eine erkennbare. Ist es möglich, zu
Unterschied zwischen den Methoden .pipe() und .subscribe() auf einem RXJS beobachten
1 Antworten
Ich vor kurzem feststellen, dass ich zurückkehren kann, einen Wert innerhalb .pipe() aber nicht in .subscribe(). Was ist der Unterschied zwischen diesen beiden Methoden? Zum Beispiel, wenn ich über diese Funktion, nennen wir es mal "Einzahlung", die
Wie Kette rxjs beobachten
1 Antworten
Ich komme aus Angular1, und wie die Verkettung Versprechen, ich möchte haben ein ähnliches Verhalten. Ich habe eine Methode in someclass:- {......... doLogin (username, password) { ....... ....... return this.http.get(api).subscribe( data => {.....}, //enters here err =>
Eckige 4 - Verkettung abonnieren
1 Antworten
Ich rufe ein webservice von Winkel-4-code und ein Abonnement für die Antwort. Wenn die Antwort kommt, muss ich analysieren und mit Hilfe der analysierten Informationen ein webservice (und abonnieren Sie die Antwort noch einmal). Wie kann ich
Sammeln RxJS Observable-Array
1 Antworten
Ich verwenden möchte, RxJS "Brücke" async Welt der Veranstaltungen mit sync-Welt. Speziell möchte ich erstellen Sie eine Funktion, die liefert ein array der gesammelten Ereignisse während bestimmter Zeit-Intervall. Kann ich Beobachten, das tut was ich will var
Angular2 HTTP mit observablen abonnieren anzeigen von Daten undefiniert
2 Antworten
Ich weiß nicht, was ich falsch mache, aber irgendwie bin ich nicht in der Lage, Daten zu Lesen, obwohl die Daten kommen vom server in der Antwort und auch die Daten bekommen, zeigte sich im service-extractData Methode,
shareReplay in RxJS 5
2 Antworten
Entsprechend der RxJS 5 MIGRATION.md es sieht aus wie shareReplay() entfernt worden. Warum? Hat .publishReplay(1).refCount() getreu repliziert das Verhalten? Im Prinzip brauche ich zum Abspielen der jeweils letzten Datensatz, um alle neuen Abonnenten. InformationsquelleAutor Philip Bulley |
Wie filter FirebaseListObservable auf der client-Seite?
3 Antworten
Ich bin mit AngularFire2 innerhalb einer Eckigen web-app. Aufgrund der query-Einschränkungen der FB, ich kann nicht form einer Abfrage, liefert genau die Informationen, die ich brauche (zumindest nicht ohne größere änderungen an meinem schema). So, ich möchte,
Winkel-6 + RxJS 6.0 : Wie push neues element zum array enthaltenen Beobachtbaren
2 Antworten
Ich bin empfangen von Daten vom FB-server in Blöcken während der Wiedergabe von Daten erfordert eine Bibliothek, die beharrt auf beobachtbaren Array enthält. Ich bin irgendwie nicht in der Lage zu schieben, eine neue Daten-chunk vorhandenen Daten-chunk
Eckige 4 - rxjs BehaviorSubject Nutzung in Service
1 Antworten
Mein Service code sieht wie folgt aus - DataService @Injectable() export class DataService { ... private serviceRequestDtoSource = new BehaviorSubject<ServiceRequestDto>(null); serviceRequestDto$ = this.serviceRequestDtoSource.asObservable(); ... getAccountInfo(serviceRequestDto : ServiceRequestDto){ let body = JSON.stringify(serviceRequestDto); let headers = new Headers({ 'Content-Type':
Wie der "flatmap" Betreiber bedingt ? (Winkel 2/rxjs)
4 Antworten
Was ich versuche zu erreichen, laufen eine Reihe von observablen bedingt. return observable.map(response => response) .flatmap(response1 => observable1(response1)) .flatmap(response2 => observable2(response2)) .flatmap(response3 => observable3(response3)) Ich brauche, um zu überprüfen, die response1 und berufen sich auf die restlichen
combineLatest veraltet, zu Gunsten der statischen combineLatest
3 Antworten
Nach dem ausführen des rxjs migration tool, mit rxjs-5--6-Migration -p src/tsconfig.app.json Ich bin jetzt immer ein linting-Fehler: combineLatest ist veraltet: Veraltet, zu Gunsten der statischen combineLatest. Hier ist mein code vor der Ausführung der migration-Befehl: this.store.combineLatest( this.store.select(lang.getCurrent),
Angular2 http " retry-Logik
2 Antworten
Habe ich eine API mit token-basierte Authentifizierung-Mechanismus. Nach erfolgreicher signin Speicher ich zwei Token im browser das lokale storage - access-und refresh-Tokens. Das access token enthält alle erforderlichen Informationen zur Autorisierung eines Benutzers auf der server-Seite und
Wie kann ich die Prozess-Ergebnisse aus http.get() im Winkel 6/RxJS 6?
1 Antworten
Ich versuche, ein upgrade einer Anwendung von Winkel 5 Winkel 6 und Schwierigkeiten haben, herauszufinden, wie man RxJS die neue syntax. Hier ist der code, den ich versuche zu migrieren: import { Injectable } from '@angular/core'; import
'Fehler' Meldung: 'Eigenschaft 'von' existiert nicht auf Typ 'typeof Beobachtbaren'
2 Antworten
Ich versuche zu lernen reaktive Programmierung mit RxJS. Ich habe versucht, erstellen Sie eine observable, die aus einem array mit zu Beobachten.aus() Methode, aber ich erhalte eine Fehlermeldung: Eigenschaft 'von' existiert nicht auf Typ 'typeof Beobachtbaren' Ich
Wie kann ich Beobachten in RxJS
3 Antworten
Sagen wir, wir haben ein Beobachtbaren: var observable = Rx.Observable .fromEvent(document.getElementById('emitter'), 'click'); Wie kann ich es machen Komplette (was löst onComplete Ereignis für alle abonnierten Beobachter) ? InformationsquelleAutor ulfryk | 2015-12-04
Was ist die "callback-Hölle" und wie und warum tut RX es lösen?
6 Antworten
Kann jemand eine klare definition zusammen mit einem einfachen Beispiel erklärt, was ein "callback-Hölle" für jemanden, der nicht weiß, JavaScript und node.js ? Wann (in welcher Art von Einstellungen) ist die "callback-Hölle-problem" auftreten? Warum tritt es auf?
Winkel 2 Weg zu bekommen, Artikel aus Beobachtbare<Xyz[]>
6 Antworten
Angesichts der folgenden Typoskript in eine Eckige 2-service: getLanguages () { return this.http.get(this._languagesUrl) .map(res => <Language> res.json().data) .catch(this.handleError); Ich habe Schwierigkeiten bei der Verwendung dieses in Umständen, in denen ich nachschlagen kann ein bestimmtes Element aus dem
RxJs: Wie eine Schleife basierend auf dem Status des beobachtbaren?
2 Antworten
Ich versuche RxJs, um eine Schleife über einen Beobachtbaren in meinem stream, bis es in einem bestimmten Zustand, dann den stream weiter. Speziell ich die Umwandlung einer synchronen do/while-Schleife RxJs, aber ich nehme an, die gleiche Antwort
RxJS alternative zu tun, ein Versprechen.beheben?
1 Antworten
Was ist das äquivalent in RxJS zu Promise.resolve? Ich weiß, ich kann tun Observable.fromPromise(Promise.resolve(someValue)); aber es muss ein sauberer Weg. Hinzufügen-bis auf alexpods Antworten, die Rx Dokumentation für beobachten und Betrachter ist wirklich aufschlussreich. InformationsquelleAutor Davy |
So entfernen Sie bestimmte Elemente aus Beobachtbare<Array<alle>>
2 Antworten
Es ist ein Beobachten von dem array von Orten: places: Observable<Array<any>>; In der Vorlage, die er verwendet, mit dem async-Leitung: <tr *ngFor="let place of places | async"> ... </tr> Nachdem einige user-Aktionen habe ich entfernen müssen, den
wie Sie sich Abmelden können mehrere Abonnenten in den Winkel-2
3 Antworten
Habe ich shareService und abonnieren, dass ist in anderen Komponenten : import { Component, Input, OnDestroy } from '@angular/core'; import { MissionService } from './mission.service'; import { Subscription } from 'rxjs/Subscription'; @Component({ selector: 'my-astronaut', template: ` <p>
Rxjs Beobachtung Objekt-updates und änderungen
3 Antworten
Ich versuche zurzeit, zu beobachten, alle änderungen zu einem Objekt inklusive aller Elemente. Dem folgenden code wird nur ausgelöst, wenn ein Objekt[x] updates, aber nicht, wenn Sie individuell Aktualisierung object[x]'s-Elemente wie Objekt[x][y] <script> var elem = document.getElementById("test1");
Zugriff auf Variablen, die eine Komponente aus einem RxJS subscribe () - Funktion
2 Antworten
Ich bin in der Lage zu verwenden this.variable um auf Variablen zuzugreifen, die in jedem Teil der Komponente, außer in den RxJS Funktionen wie subscribe() oder catch(). Im Beispiel unten, ich will so drucken Sie eine Nachricht