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.

shareReplay in RxJS 5

Anzahl der Antworten 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?

Anzahl der Antworten 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

Anzahl der Antworten 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

Anzahl der Antworten 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)

Anzahl der Antworten 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

Anzahl der Antworten 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

Anzahl der Antworten 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?

Anzahl der Antworten 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'

Anzahl der Antworten 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

Anzahl der Antworten 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?

Anzahl der Antworten 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[]>

Anzahl der Antworten 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?

Anzahl der Antworten 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?

Anzahl der Antworten 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>>

Anzahl der Antworten 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

Anzahl der Antworten 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

Anzahl der Antworten 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

Anzahl der Antworten 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

Ist es notwendig, zum abbestellen von observablen erstellt von Http-Methoden?

Anzahl der Antworten 8 Antworten
Müssen Sie die Abmeldung aus Winkel-2 http-Aufrufe zu verhindern, Speicherverlust? fetchFilm(index) { var sub = this._http.get(`http://example.com`) .map(result => result.json()) .map(json => { dispatch(this.receiveFilm(json)); }) .subscribe(e=>sub.unsubscribe()); ... Mögliche Duplikate von Verhindern von Speicherlecks im Winkel 2? Siehe stackoverflow.com/questions/34461842/...

Wie man der "aktuellen" Wert, von einem Beobachter zu abonnieren-Zeit

Anzahl der Antworten 1 Antworten
Ich habe eine harte Zeit grokking ein bestimmter Teil des RxJs: wenn Sie sich registrieren, um eine Beobachtbare, du bist nur abonnieren alle Zukunft Ereignisse aus dem Stream. Vergleichen Sie Versprechen, wo, wenn das Versprechen wurde aufgelöst,

Geben Sie \'Beobachtbare<{}>\" ist nicht zuordenbar geben Sie in den Winkel-2

Anzahl der Antworten 1 Antworten
Beobachtbar ist nicht assigend, mein Paket.json-Datei enthält "angular2": "2.0.0-beta.17", "systemjs": "0.19.24", "es6-promise": "^3.0.2", "es6-shim": "^0.35.0", "reflect-metadata": "0.1.2", "rxjs": "5.0.0-beta.6", "zone.js": "0.6.12" Problem geschieht, während mein terminal kompilieren zeigt er mir eine Fehlermeldung Nachricht: '\u001b[31mresources/assets/Typoskript/Dienstleistungen/Benutzer.service.ts(25,5): \u001b[39merror TS2322: Geben

Angular2 Zusammenführen von observablen

Anzahl der Antworten 6 Antworten
Ich habe Probleme dabei mit manchen observablen. Ich kann nicht scheinen, um zwei observablen zu Ort schön zusammen. Sie funktioniert gut auf Ihre eigenen, aber ich müssen beide Werte. db.glass.subscribe( ( glass: GlassData ): void => {

RxJS beobachtbar ist nicht abgeschlossen, wenn ein Fehler Auftritt

Anzahl der Antworten 3 Antworten
Wenn ich eine beobachtbare, von Grund auf, und haben die Beobachter-Fehler, dann komplett fertig Teil der Abonnement-nie aufgerufen. var observer = Rx.Observable.create(function(observer){ observer.onError(new Error('no!')); observer.onCompleted(); }) observer.subscribe( function(x) { console.log('succeeded with ' + x ) }, function(x)

Testen Sie eine Methode, die abonniert ist, um eine beobachtbare - Winkel-2

Anzahl der Antworten 3 Antworten
Ich möchte zum testen eine Methode innerhalb einer Eckigen 2-Komponente abonniert ist, um eine beobachtbare, der zurückgegeben wird, von einer Methode in einem Dienst. Hier ist der code für die service-Methode in der Zusammenfassung: public create(user: User):

was ist ein `Scheduler` in RxJS

Anzahl der Antworten 1 Antworten
I ' V gesehen der Begriff Scheduler sehr Häufig in der Dokumentation. Aber, was bedeutet dieser Begriff? Ich selbst weiß nicht, wie die Verwendung von sogenannten Scheduler. Die offizielle Dokumentation nicht sagen, was mir ein Scheduler genau

Zurück ein leerer Beobachten

Anzahl der Antworten 11 Antworten
Die Funktion more() soll, um eine Observable aus einer get-Anfrage export class Collection{ public more = (): Observable<Response> => { if (this.hasMore()) { return this.fetch(); } else{ //return empty observable } } private fetch = (): Observable<Response>

Was bedeutet die "Karte" - Methode bedeutet in RxJS?

Anzahl der Antworten 2 Antworten
Ich Lerne RxJS durch das Lesen dieses tutorial http://reactive-extensions.github.io/learnrx/. Ich habe eine harte Zeit zu verstehen die anzeigen Methode der Observable. Die Array version von map ist wirklich einfach und unkompliziert. Ich habe keine Ahnung, was genau

RxJS: Wie man nicht abonnieren, um Anfangswert und/oder undefiniert?

Anzahl der Antworten 5 Antworten
Wird neu in RxJS ich oft erstellen Sie ein Thema, das hält Werte in der Zukunft, sondern ist zunächst undefined. Es kann nur sein undefined ersten mal. Derzeit nutze ich ein filter zu überspringen undefined Werte, aber

So finden Sie ein element von einem array von id mit Beobachtbaren in Angular2

Anzahl der Antworten 1 Antworten
Beschloss ich, Beobachten statt Http verspricht. So mein Versprechen-Dienst sah: export class MovieService { movies: Movie movie: Movie; constructor(private http:Http) { } getMovies(): Promise<Movie>{ return this.http.get('http://api.request.com') .toPromise() .then((res:Response) => res.json()['results']) } getMovie(id: number): Promise<Movie> { return this.getMovies()

Wie behandeln Fehler in einem Resolver

Anzahl der Antworten 2 Antworten
Ich versuche, Resolver, um eine bessere UX. Funktioniert alles Super auf den happy path. Was kann ich nicht scheinen, um herauszufinden, ist, wie die Behandlung von Ausnahmen. Mein resolver einen Dienst aufruft, und das trifft ein webapi-Projekt.

FEHLER in node_modules/rxjs-compat/Betreiber/shareReplay.d....ts(2,10): Fehler TS2305:

Anzahl der Antworten 5 Antworten
Ich versuche, ein upgrade einer basic-Winkel-Skelett-app von Winkel 5 Winkel 6 und hier ist das Problem, ich komme über Sie beim ausführen der app : ERROR in node_modules/rxjs-compat/operator/shareReplay.d.ts(2,10): error TS2305: Module '"C:/newAdmin/testing-front-end/admin-fe/node_modules/rxjs/internal-compatibility/index"' has no exported member 'ShareReplayConfig'.

node_modules/rxjs/interne/ - Typen.d....ts(81,44): Fehler TS1005: ';' erwartet, dass Fehler nach der installation von Winkel 6

Anzahl der Antworten 11 Antworten
Ich bekam eine Fehlermeldung von node_modules/rxjs/internal/types.d.ts(81,44): error TS1005: ';' expected. nach der installation der Eckige 6. Überprüfen Sie die Fehlermeldung: 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: ';' expected. node_modules/rxjs/internal/types.d.ts(81,77): error TS1109: Expression expected.

Eckige 2 - *ngif nicht erfrischend, wenn variable update von oberservable abonnieren

Anzahl der Antworten 2 Antworten
in der html habe ich die Warnung sollte nur gezeigt werden, wenn ein Fehlerzustand Auftritt, wie thius <div class="alert alert-danger" *ngIf="error"> <strong>Not saved!</strong> There was an error when saving the project. Please try again later. </div> diese

Typ 'Beobachtbare<alle>' ist nicht belegbar zu geben '[]'

Anzahl der Antworten 3 Antworten
Ich bin ziemlich neu in Angular2/Typoskript, so bitte entschuldigen Sie mich, wenn ich tun einige dumme Fehler. Was ich versuche zu tun, ist Wählen Sie aus drop down ich bin, Auffüllen der Daten mit service, die Rückkehr

Angular2 Beobachten - Wie Sie als Nächstes anrufen von außerhalb des Beobachtbaren Konstruktor

Anzahl der Antworten 3 Antworten
Ich bin Aufbau eines service, durch den eine Observable. In diesem service, den ich erhalten externe Funktionsaufrufe, die auslösen sollte, ein Nächster Anruf auf das Beobachtbare, so dass verschiedene Verbraucher bekommen die Abo-Falle. Während Beobachter Konstruktor kann

Wie kann ein mock ein http, erkennbar im Angular2, wenn keine api geschrieben

Anzahl der Antworten 1 Antworten
Ich bin neu sowohl Angular2 und Rxjs und ich bin ein wenig verwirrt über einen bestimmten Fall. Ich habe einen einfachen service: import { Injectable } from '@angular/core'; import { Observable, Subject } from 'rxjs/Rx'; import {

Error: Can ' T resolve 'rxjs/add/Betreiber/Karte"

Anzahl der Antworten 3 Antworten
Dies ist app.module.ts ich habe versucht zu tun, den Import von map in unterschiedlichen Projekt-und es funktionierte gut, aber in diesem Projekt funktioniert es nicht. import { BrowserModule } from '@angular/platform-browser'; import { NgModule } from '@angular/core';

Winkel - HttpClient: Anzeigen Get-Methode-Objekt Ergebnis der array-Eigenschaft

Anzahl der Antworten 5 Antworten
Ich bin eine API aufrufen, gibt eine JSON-Objekt. Ich brauche nur den Wert des Arrays anzeigen, um einen zu Beobachten . Wenn ich call-api, die nur gibt die array-meine service-Aufruf funktioniert. Unten ist mein Beispiel-code .. //my

Haben Komponente Funktion ausführen nach dem Dienst http.get-Aufruf beendet ist

Anzahl der Antworten 4 Antworten
Ich habe echt Mühe wickeln meinem Kopf herum observablen und Abonnements in angular2. Das problem, das ich derzeit habe ist Folgendes: Habe ich einen Dienst, der enthält Methoden post und get Daten aus einer API. Der service

Abonnieren Sie mehrere Observablen (wie die Verkettung dann() in Verspricht)

Anzahl der Antworten 2 Antworten
Meine Winkel 2 Anwendung 2 Methoden (GetCategories() und GetCartItems()) in einem Dienst , und diese beiden Methoden zurück Observables. In der Reihenfolge zu berufen, diese zwei Methoden eine nach der anderen von meiner Komponente, die ich geschrieben

RxJs bekommen Wert aus beobachtbaren

Anzahl der Antworten 2 Antworten
In-Komponente : singleEvent$: Observable<Event>; Auf init, bekomme ich beobachtbaren this.singleEvent$ = this._eventService.events$ .map(function (events) { let eventObject = events.find(item => item.id === eventid); let eventClass: Event = new Event(eventObject); return eventClass; }); Wie kann ich den aktuellen

Diese Eigenschaft fromEvent existiert nicht auf Typ 'typeof Beobachtbaren' Winkel 6

Anzahl der Antworten 2 Antworten
Ich habe ein problem, die versuchen, um zu drehen Sie das keyup Ereignisse in eine beobachtbare stream. Ich bin nach dem Ng-book-version 6. Ich stecke in einem Beispiel, dass eine Suche YouTube-video, wie Sie geben. Wenn die

Wie zu propagieren und Fehler durch catchError() richtig?

Anzahl der Antworten 1 Antworten
Ich schrieb eine Funktion, die pipe-Lage: HandleHttpBasicError<T>() { return ((source:Observable<T>) => { return source.pipe( catchError((err:any) => { let msg = ''; if(err && err instanceof HttpErrorResponse) { if(err.status == 0) msg += "The server didn't respond"; }

Angular2 Formular-Steuerelement valueChanges beobachtbaren komplette nie genannt

Anzahl der Antworten 3 Antworten
Ich bin derzeit versuchen zu zeigen, einen einfachen loader auf meiner Suche bar, während die Suche stattfindet. Ich habe geplant, um eine variable festzulegen, die in der subscribe callback auf die valueChanges beobachten aus meinem Formular-Steuerelement zu

angular2-map-Daten bestimmter Objekt-Typ

Anzahl der Antworten 3 Antworten
Ich erstellte eine sehr einfache app, basierend auf der Angular2 tutorial. Starten, ich habe eine sehr einfache "Buch-Modell": /** * book model */ export class Book { public data; /** * constructor * @param id * @param

Rxjs Thema next() nach dem vollständigen()

Anzahl der Antworten 1 Antworten
Habe ich Dienst und verbindet mit Subject() zu tun paging. Ich bin mit next(newData) passieren zu unterliegen, was hält die Dinge lebendig, jetzt muss ich verwenden complete() auf jedem ajax-Aufruf übergeben und zu Unterwerfen. aber nachdem ich

Angular2: Maus-event-handling (Bewegung relativ zur aktuellen position)

Anzahl der Antworten 2 Antworten
Meine Benutzer sollen in der Lage sein, sich zu bewegen (oder zu drehen) auf ein Objekt mit der Maus in eine Leinwand. Wenn Mausereignisse auftreten, die Bildschirm-Koordinaten werden verwendet, um die Berechnung der delta (Richtung und Länge)

Wie man einen http-Aufruf alle 2 Minuten mit RXJS?

Anzahl der Antworten 3 Antworten
Habe ich einen service zu machen, dass ein Anruf auf mein rest-service alle 2 Minuten. Auf meinem service ich habe die folgende Funktion getNotifications(token: string) { const body = 'xxxxxxxxx=' + token; return this.http.post('/rest/ssss/ddddddd/notificationcount', body, this.options) .map((res)

Wie konvertieren Beobachten<alle> array[]

Anzahl der Antworten 4 Antworten
Habe ich folgende Methode in Typoskript, ich zu binden, müssen eckige Gitter CountryService GetCountries() { return this.http.get(`http://services.groupkt.com/country/get/all`) .map((res:Response) => <CountryData>res.json().RestResponse["result"]); } GridComponent template: ` <ag-grid-ng2 style="width: 100%" #agGrid class="ag-material" rowHeight="50" [gridOptions]="myGridOptions" > </ag-grid-ng2> `, this.myGridOptions.rowData= this.CountryService.GetCountries(); CountryData

Wie stellen Sie den countdown-timer mit RxJS Observablen?

Anzahl der Antworten 2 Antworten
Ich bin kämpfen, um erstellen Sie einen countdown-timer mit Observablen, die Beispiele auf http://reactivex.io/documentation/operators/timer.html nicht zu funktionieren scheint. In diesem konkreten Beispiel wird der Fehler bezogen auf timerInterval nicht eine Funktion des Beobachtbaren kehrte aus-timer. Habe ich