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.
Ist es notwendig, zum abbestellen von observablen erstellt von Http-Methoden?
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
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
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
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
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
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
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
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?
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?
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
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
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:
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
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
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 '[]'
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
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
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"
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
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
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)
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
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
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?
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
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
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()
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)
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?
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[]
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?
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
Immer ein object-array aus einer Eckigen service
1 Antworten
Ich bin neu Eckig (und Javascript für diese Angelegenheit). Ich habe geschrieben ein Eckiges service gibt ein array von Benutzern. Der Abruf von Daten aus einer HTTP-Aufruf liefert die Daten im JSON-format. Bei der Anmeldung werden die
Was ist der Unterschied zwischen Versprechen und Observablen?
23 Antworten
Kann mir bitte jemand erklären den Unterschied zwischen Promise und Observable im Eckigen? Ein Beispiel zu jedem wäre hilfreich beim Verständnis der Fälle. In welchem Szenario können wir jeweils? Ich würde dir empfehlen, diesen Beitrag zu Lesen;
Emittieren einen einzelnen Wert
2 Antworten
Ich würde gerne emittieren einen einzelnen Wert. Gemäß dieser post, sollte Folgendes gelten: var requestStream = Rx.Observable.just('https://api.github.com/users'); Jedoch, funktioniert dies nicht. just ist nicht definiert. Ist es schon veraltet? Gibt es etwas, das ich stattdessen verwenden können?
Wie erstellen Sie Beobachten von der Funktion?
3 Antworten
Möchte ich eine Funktion aufrufen (synchron) und dann mit dessen Rückgabewert als eine erste emission (anschließend Verkettung einigen anderen Anbietern, die daraus resultierenden messbaren). Ich soll zum aufrufen dieser Funktion im Abonnement, ich kann also nicht einfach
Eckige 2 - Typoskript: TS2322: Typ Abonnement ist nicht übertragbar auf Typ 'Beobachtbare<MouseEvent>'
1 Antworten
Ich bin mit dem click-Richtlinie außerhalb von diesem plunk --> http://embed.plnkr.co/v7BMUv/ Meine TS-compiler wirft folgenden Fehler: TS2322: Typ Abonnement ist nicht übertragbar auf Typ 'Beobachten'. Eigenschaft '_isScalar" fehlt im Art 'Abonnement'. TS2339 Eigenschaft 'Abmelden' existiert nicht auf
werfen Fehler in rxjs Beobachten
3 Antworten
Ich versuche zu werfen, einen Fehler innerhalb einer rxjs Beobachtbaren new Observable(subscriber => { Observable.throw("error1"); return Observable.throw("error2"); }) .subscribe( () => {}, err => console.error(err) ); Fehler 1 ist nicht gefangen. error2 gibt einen Kompilierungsfehler: Argument of
RxJS Sequenz äquivalent zu Versprechen.dann()?
7 Antworten
Ich verwendet, um eine Menge mit Versprechen und jetzt bin ich bewegt, um RxJS. Der doc RxJS nicht geben ein sehr klares Beispiel, wie man von Versprechen Kette Beobachter Sequenz. Zum Beispiel, Schreibe ich normalerweise Versprechen Kette
Eigenschaft Intervall existiert nicht in der Art beobachten
3 Antworten
ngAfterViewInit(){ Observable.interval(3000).timeInterval().subscribe()=>{}; } Versuch zum aufrufen des Beobachtbaren.Intervall () - Methode wirft einen compiler-Fehler "Intervall-Eigenschaft existiert nicht in der Art beobachten". Bearbeiten import { Observable } from 'rxjs/Observable'; Beachten Sie, dass die import-Anweisung ist bereits im Lieferumfang
Was bedeutet die .subscribe () - Funktion?
2 Antworten
Ich bin der Codierung eine API mit Angular2 und NodeJS ich bin die Implementierung der Dienste für meine ِAPI, die soll eine Liste mit den Aufgaben und anzeigen. Hier ist der task-service: import {Injectable} from '@angular/core'; import
Winkel-5 - 'json nicht existiert auf dem Typ Object'
5 Antworten
Bin ich nach einem einfachen Leitfaden und zur änderung der es leicht für meine Bedürfnisse - Aber ich habe endlich einen Haken über mapping und subscribing https://www.sitepoint.com/mean-stack-angular-2-angular-cli/ - Dies ist die Anleitung, und alles funktioniert, bis ich
Nicht finden können Modul 'rxjs-compat/Beobachtbare'
5 Antworten
Ich bin derzeit auf der Upgrade-eckig 4-eckig 6-code. Ich habe installiert "rxjs": "^6.3.2" und un-installiert rxjs-compact als ich migriert der code zur Verwendung der neuen rxjs Betreiber. Ich bin noch immer der folgende Fehler. Weiß nicht, der
Erstellen Sie ein one-time-Abo
3 Antworten
Brauche ich zum erstellen eines Abonnements für einen Observable wird sofort entsorgt, wenn er zuerst genannt. Gibt es so etwas wie: observable.subscribeOnce(func); Meine, ich bin ein Abonnement erstellen, die in einer express route-handler und das Abonnement wird
Angular2 route guard Rückkehr Beobachten<bool>, wie, um Fehler zu behandeln
1 Antworten
Habe ich eine route guard wie unten @Injectable() export class AuthGuard implements CanActivate { constructor(private router: Router, private authenticationSvc: AuthenticationService) { } canActivate(): Observable<boolean> { return this.authenticationSvc.getAuthenticatedUser().map( r => { if (this.authenticationSvc.isAuthenticated()) { //logged in so return
Wie erstelle Verhalten Subjekt zum Objekt, und abonnieren Sie Sie auf eine andere Komponente?
2 Antworten
Habe ich eine Verhalten-Thema in eine service-Klasse. public personObject: BehaviorSubject<any> = new BehaviorSubject<any>({ personId: 1, name: 'john doe' }); Auf eine Komponente, die Einfuhren dieser Dienstleistung, die ich abonniert haben dieses Verhalten Thema wie folgt: ` this._subscription.add(
Beobachtbar ist.forkJoin() nicht ausgeführt wird
4 Antworten
Ich habe den folgenden code: //Loop: For each user ID/Role ID, get the data userMeta.forEach((businessRole) => { Observable.forkJoin( af.database.object('/roles/'+businessRole.$value), af.database.object('/users/'+businessRole.$key) ).subscribe( data => { console.log("Data received"); data[1].role = data[0]; this.users.push(data[1]); }, err => console.error(err) ); Ich versuche
AngularJs - RXJS Beobachtbaren Abmelden
2 Antworten
Ich habe setup eine RXJS zu beobachten. Ich habe zwei Komponenten die Sie abonnieren, um ein Thema in der service-Fabrik. Wie kann ich mich Abmelden, eine ausgewählte Komponente, um das Thema so, dass eine Taste gedrückt wird,
Rxjs Wiederholen mit Delay-Funktion
8 Antworten
Ich versuche, mit retry mit delay Funktion erwarte ich von der Funktion Anruf nach 1000ms Verzögerung, aber es doesnot, was kann der Fehler hier? Blick auf die Ausgabe in der Konsole, es ist der gleiche time 16:22:48.
Winkel-6-router.Veranstaltungen.filter 'filter' existiert nicht auf Typ 'Beobachtbare<Fall>'
2 Antworten
Habe ich fertig, update meiner App zum Winkel 6 (es wurde in 5.2-version). Bekam ich einen syntax Fehler in : import { Router, ActivatedRoute, NavigationEnd } from '@angular/router'; import { filter } from 'rxjs/operators'; ... constructor(private router: