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.
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
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
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
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?
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
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
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
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);
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
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:
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
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
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
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 }
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
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
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
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
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
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 =
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() ||
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
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,
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,
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
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
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
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
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 =>
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
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
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,
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 |
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,
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
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':
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
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),
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
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
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
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
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?
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
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
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 |
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
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>
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");
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