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.

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

Immer ein object-array aus einer Eckigen service

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Verkettung Observablen in RxJS

Anzahl der Antworten 1 Antworten
Ich Lerne RxJS und Eckig 2. Sagen wir, ich habe ein Versprechen Kette mit mehreren asynchronen Funktionsaufrufen, mit denen abhängen, die auf dem vorhergehenden Ergebnis, das wie folgt aussieht: var promiseChain = new Promise((resolve, reject) => {

Eckige 2 - Mehrere HTTP-Anfrage in der gleichen Zeit

Anzahl der Antworten 2 Antworten
Bin ich tatsächlich arbeiten auf eine Eckige 2-Anwendung, aber ich habe ein paar Probleme. In der Tat, ich habe eine Methode, die Daten aus einer Datenbank. Aber ich versuche, kopieren Sie diese Daten auf einen anderen ein,

Node_modules/rxjs/Rx"' hat keine exportiert Mitglied 'Rx'

Anzahl der Antworten 5 Antworten
Können Sie mir sagen, warum unten Verhalten mit rxjs/Rx? Ich bin mit VS code V 1.14.1. Dies funktioniert: import * as Rx from 'rxjs/Rx'; und import Rx from 'rxjs/Rx'; Aber Das wird nicht funktionieren. import { Rx

Eckig/RxJs Wann sollte ich mich Abmelden von `Abonnement`

Anzahl der Antworten 16 Antworten
Wann sollte ich mit der Speicherung der Subscription Instanzen und berufen unsubscribe() während der NgOnDestroy Lebenszyklus und Wann kann ich Sie einfach ignorieren? Speichern Sie alle Abonnements, bringt eine Menge Durcheinander in die Komponente-code. HTTP-Client-Handbuch ignorieren Abonnements

Winkel-6-Update - rxjs-5--6-migrate-Befehl nicht gefunden

Anzahl der Antworten 3 Antworten
In der upgrade-Prozess von update.eckig.io: Entfernen veraltet RxJS 6 Funktionen mit rxjs-tslint auto-update-Regeln. Für die meisten Anwendungen wird dies bedeuten, dass die beiden folgenden Befehle ausführen: npm install -g rxjs-tslint rxjs-5-to-6-migrate -p src/tsconfig.app.json Aber wenn ich gehen

wie Sie Sie abonnieren, um eine beobachtbare in einen anderen Dienst im Winkel 2

Anzahl der Antworten 1 Antworten
Ich habe einen service, der einfach sagt, wenn ein Benutzer angemeldet ist oder nicht. Es wird aktualisiert von einem anderen Dienst, die die http-Anforderung, um zu überprüfen, der Nutzer. Möchte ich ein nav-bar-Komponente für die Aktualisierung der

Karte existiert nicht auf Beobachtbaren<Object> mit kantigem 6.0.0 und rxjs 6.1.0

Anzahl der Antworten 6 Antworten
Hallo, ich versuche zu Folgen, ein tutorial auf eckig aber das tutorial war im September. Ich glaube, die person benutzt, eckig-cli 1.3.2. Ich bin mir nicht sicher, welche version von rxjs er war mit. Ich bin mit

Winkel-6 ng lint combineLatest ist veraltet

Anzahl der Antworten 3 Antworten
Habe ich vor kurzem aktualisiert Winkel 5 Winkel 6. Ich bekomme diese Warnung combineLatest is deprecated: resultSelector no longer supported, pipe to map instead. Rxjs ist die version 6.1.0, tslint ist 5.10.0 -, Winkel-CLI ist 6.0.0 und

Holen Sie string-Wert aus Beobachtbaren<string> in Maschinenschrift und Eckig

Anzahl der Antworten 1 Antworten
Möchte ich, um string-Wert aus Beobachtbaren und Wert aus der Funktion an den Aufrufer der Funktion. ZB: Ich habe die array-Schlüssel und würde gerne Hole den Wert (string), alle Schlüssel nacheinander und Anzeige von html-Komponenten die Menüleiste.

Unter Verwendung der ersten () - operator auf eine beobachtbare, um das erste element

Anzahl der Antworten 2 Antworten
Ich bin Art von neuen zu RxJS, In diesem plunk Ich bin versucht, zurück das erste Element im array ist, habe ich versucht das first() Betreiber, aber es gibt nichts: var one = this.http.get(this.memberUrl) .map( this.extractData )

Richtige Weg, um ein upgrade RxJS auf neueste version?

Anzahl der Antworten 3 Antworten
Wenn Sie versuchen, installieren Sie die neueste version von RxJS, Ich verwendet npm install rxjs wie in dieser Dokumentation erläutert: https://github.com/reactivex/rxjs Aber ich habe diese Warnungen: npm warnen @angular/[email protected] erfordert ein peer [email protected]^5.5.0 aber keiner installiert ist.

Winkel-6 - ForkJoin hat keine exportiert Mitglied

Anzahl der Antworten 3 Antworten
Habe ich aktualisiert Winkel 6 und ich bin versucht zu verwenden ForkJoin, also über mein service, den ich haben: import { forkJoin } from 'rxjs/observable/forkJoin'; Aber es ist nicht die Anerkennung ist, und ich bin immer: ...ForkJoin

Observablen: Komplette vs endlich vs gemacht

Anzahl der Antworten 2 Antworten
Beim sprechen über Observablen (insbesondere rxjs), was ist der Unterschied zwischen "endlich" und "erledigt" oder "abgeschlossen"? InformationsquelleAutor Alexander Taylor | 2017-06-27

TypeError: Sie bereitgestellt, 'undefined', wobei ein stream zu erwarten war

Anzahl der Antworten 6 Antworten
Ich habe eine Ionische Anwendung, die eine user Anbieter mit einem signup() Methode: doSignup() { //set login to same as email this.account.login = this.account.email; //Attempt to login in through our User service this.user.signup(this.account).subscribe((resp) => { this.navCtrl.push(MainPage); },

tslint Fehler Überschattet, name: 'Beobachtbar'

Anzahl der Antworten 3 Antworten
Bin ich immer die folgende Fehlermeldung beim ausführen tslint, dass ich nicht immer vor.. ERROR: C:/...path..to../observable-debug-operator.ts[27, 13]: Shadowed name: 'Observable' Ich folgte diesem tutorial für das hinzufügen einer debug-operator, Observable und es ist in Ordnung, außer ich

Winkel 5 abonnieren und abbestellen Beobachten

Anzahl der Antworten 1 Antworten
Habe ich, um Daten aus zwei abonnieren, aber ich bekomme immer die Daten des ersten. Habe ich eine Daten-shared service : import { Injectable } from '@angular/core'; import { BehaviorSubject } from 'rxjs/BehaviorSubject'; @Injectable() export class DataService

Winkel-5-6 Aktualisieren: Eigenschaft 'anzeigen' existiert nicht auf Beobachtbaren Typ

Anzahl der Antworten 4 Antworten
Ich habe aktualisiert mein angular Anwendung von version 5 auf 6 und ich bin immer dieser Fehler aus folgenden code. const request = this.evidenceService.get().map((res) => res.data) .catch(error => Observable.of(null)); Eigenschaft 'anzeigen' nicht vorhanden ist auf dem Typ

Winkel 4, Wie man richtig eine void zurückgeben beobachten

Anzahl der Antworten 3 Antworten
In meinem Winkel 4 Anwendung habe ich eine Methode haben, um eine beobachtbare, diese Methode haben 3 Bedingungen, ersten und zweiten Bedingungen machen einen get-Aufruf, aber der Dritte Bedingungen haben nichts zu tun und ich habe in

Winkel-4: Modul nicht gefunden Fehler bezüglich RxJs

Anzahl der Antworten 6 Antworten
beim Bau des Angular-app bekomme ich viele dieser Fehler, unten ist nur der erste ERROR in ./~/@reactivex/rxjs/dist/cjs/Rx.js Module not found: Error: Can't resolve './add/operator/filter' in '...\node_modules\@reactivex\rxjs\dist\cjs' @ ./~/@reactivex/rxjs/dist/cjs/Rx.js 70:0-32 @ ./~/@reactivex/rxjs/index.js @ ./~/ri-api-client/dist/index.js @ ./src/app/core/api.service.ts @ ./src/$$_gendir/app/app.module.ngfactory.ts

Argument vom Typ '{header:Kopfzeile;}' ist nicht zuweisbare parameter des Typs "RequestOptionsArgs'

Anzahl der Antworten 3 Antworten
Im Immer folgende Fehlermeldung beim Versuch, den pass-header in HTTP.POST/GET Anfrage Argument of type '{header:Header;}' is not assignable to parameter of type 'RequestOptionsArgs'. Property 'null' is missing in the type '{header:Header;}' Ich habe versucht viele Lösungen, aber

RxJS Map-array zu beobachten und zurück zu Ebene-Objekt im array

Anzahl der Antworten 1 Antworten
Ich habe ein array von Objekten, von denen ich mich übergeben muss jedes Objekt einzeln in die async-Methode (Prozess hinter gehandhabt wird mit Versprechen und dann umgewandelt wieder zu Beobachten über Observable.fromPromise(...) - dieser Weg ist erforderlich,