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.

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 rxjs@^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,

Wie zu verwenden Thema und debounce mit RxJs 5 aus einem string-input

Anzahl der Antworten 1 Antworten
Ich nicht bekommen, wie sich die Subjekt-Objekt arbeiten würde, für eine Vorschlag/Search service, dass ich versuche, umzusetzen Angular2. Lassen Sie uns sagen, dass generateSuggestions aufgerufen wird jedes mal, wenn ein input-Veränderungen, für eine AutoVervollständigen verwenden. Ich verstehe

I dont get rxjs 6 mit eckiger 6 mit Intervall, switchMap und anzeigen

Anzahl der Antworten 2 Antworten
Ich will update my rxjs code 6 habe ich nicht bekommen. Ich hatte vor, den unteren, wouth Umfrage für neue Daten alle 5 Sekunden: import { Observable, interval } from 'rxjs'; import { switchMap, map } from

Winkel-2: Cannot read property 'unsubscribe' von undefined

Anzahl der Antworten 3 Antworten
Ich versuche zum erstellen einer ObservableTimer, dass Zecken bis zu einer bestimmten Anzahl. Ich habe schon Logik zu tun, aber wenn ich versuche, mich Abmelden bekomme ich eine "Cannot read property 'unsubscribe' of undefined" Fehler. Hier ist

.teilen() mit .subscribe() _isScalar fehlt

Anzahl der Antworten 1 Antworten
Ich versuche, mit share() mit subscribe() bekam aber Fehlermeldung wie folgt. Zunächst begann ich mit abonnieren. Wie kann man das beheben? Meine Absicht ist, führen Sie die Logik zu abonnieren. Freigabe ist erforderlich, um zu verhindern, dass

Angular2 rxjs Art (beobachtbaren) Liste von Objekten, die durch eine beobachtbare Feld

Anzahl der Antworten 5 Antworten
Möchte ich so Sortieren Sie eine Liste der Dinge, die durch eine beobachtbare Feld, aber kann nicht umbrochen, mein Kopf herum observablen, damit es funktioniert. Hat jemand eine Idee, wie dies zu erreichen? Die Ausgangssituation ist so

Rx js Verständnis der lift-Methode

Anzahl der Antworten 1 Antworten
Möchte ich einen neuen operator erstellen, und ich finde in der Dokumentation, dass eine der Möglichkeiten ist, so etwas zu tun: class MyObservable extends Observable { lift(operator) { const observable = new MyObservable() observable.source = this; observable.operator

Typ beobachtbare<{}> ist nicht übertragbar auf jede Art:Eigenschaft Länge fehlt in der type{} in Typoskript

Anzahl der Antworten 6 Antworten
Ich versuche, JSON-Daten im lokalen system Verwendung von Angular2 http. import { Injectable } from '@angular/core'; import { Http, Response } from '@angular/http'; import { General } from './general'; import { Observable } from 'rxjs/Observable'; @Injectable() export

Element hinzufügen auf Beobachtbare array Typoskript

Anzahl der Antworten 1 Antworten
Habe ich eine eckige 2-Komponente, die über die Nutzung des Dienstes, ist das abrufen von Daten aus der rest-api. import { OnInit, Component } from '@angular/core'; import { Hero } from './hero'; import { HeroService } from

Winkel 6 RXJS Import-Syntax?

Anzahl der Antworten 5 Antworten
Bin ich bei der Migration eines Winkel-5-app auf die neueste CLI und Eckig 6 RC und alle meine Beobachtbaren Importe sind gebrochen. Ich sehe, dass Winkel 6 ändert sich die Art und Weise der Importe funktionieren, aber

Sortieren-array in RxJS

Anzahl der Antworten 2 Antworten
RxJava hat eine Methode toSortedList(Comparator comparator) wandelt einen Fluss von Objekten in eine Liste von Objekten sortiert, die von einem Komparator. Wie kann ich erreichen das gleiche in JavaScript mit RxJS und erhalten eine Beobachtbare mit einem

Synchrone Funktionen - in Angular2

Anzahl der Antworten 1 Antworten
Ich brauchen, um zu erreichen in den Winkel-synchrone-Funktionen (, die anderen warten auf das Ende des ersten). Zum Beispiel habe ich zwei Anbieter (MenuProvider und ShopProvider). MenuProvider hat eine Methode : getMenuItemsForCurrentShop() dass über HTTP ruft die

RxJs Beobachten mit WebSocket

Anzahl der Antworten 3 Antworten
Mein angular-Anwendung verwendet eine websocket-Kommunikation mit dem backend. In meinem test-Fall habe ich 2 client-Komponenten. Die Beobachtbaren timer druckt zwei verschiedene client-id ist wie erwartet. Jeder ngOnInit() druckt auch die id des Kunden. NUN aus irgendeinem Grund,

Auf die Implementierung einer debounce-Zeit im keyup-Ereignis im Winkel 6

Anzahl der Antworten 5 Antworten
Erstelle ich eine Eckige app, suchen Sie Studenten aus der API. Es funktioniert gut, aber es ruft die API jedes mal, wenn ein Eingabewert geändert wird. Ich habe recherchiert, dass ich etwas brauche aufgerufen, debounce ,aber ich

Winkel-4-display-aktuelle Uhrzeit

Anzahl der Antworten 4 Antworten
, Was den korrekten (kanonischen) Möglichkeit zur Anzeige der aktuellen Zeit, im Winkel 4 change-detection-system? Das problem ist wie folgt: aktuelle Zeit ändert sich ständig, in jedem moment per definition. Aber es ist nicht nachweisbar durch Eckige

Eigenschaft 'abonnieren' existiert nicht auf Typ '() => Beobachten<alle>'

Anzahl der Antworten 2 Antworten
service-Datei import { Observable } from 'rxjs/Rx'; import { Http,Response} from '@angular/http'; import { Injectable } from '@angular/core'; import 'rxjs/add/operator/Map'; @Injectable() export class VideoService { private geturl='/api/videos'; constructor(private _http:Http) { } getvideos() { return this._http.get(this.geturl) .map((response:Response) =>

Was ist pipe () - Funktion im Winkel 2?

Anzahl der Antworten 4 Antworten
Rohre sind Filter für die Umwandlung von Daten (- Formate) in die Vorlage. Stieß ich auf die pipe() Funktion als unten. Was hat das pipe() Funktion genau in diesem Fall bedeuten? return this.http.get<Hero>(url) .pipe( tap(_ => this.log(`fetched

Eckige filter-Observable-array

Anzahl der Antworten 2 Antworten
Ich habe ein Observable-array und ich möchte zu filtern/finden Sie den Projekt-Namen. Wenn ich versuche, verwenden Sie die filter-option, es ist nämlich ProjectService.ts import { Injectable } from '@angular/core'; import { Project } from "../classes/project"; import {

RxJs und Typoskript. TS2307: Cannot find module '@reactivex/rxjs'

Anzahl der Antworten 6 Antworten
Hab ich ein problem mit Typoskript und RxJs v5. Bitte Schauen Sie das UPDATE Abschnitten. Habe ich yarn add @reactivex/rxjs (auch yarn add rxjs) und auf meinem index.ts hat import Rx from '@reactivex/rxjs'; und bekam diese Fehlermeldung:

Angular2 Beobachten mit Intervall

Anzahl der Antworten 1 Antworten
Ich habe eine Funktion, die aufgerufen werden muss etwa alle 500ms. Die Art, wie ich auf der Suche bin, es zu tun mit angular2 ist mit Abständen und observablen. Ich habe versucht diese Funktion zu erstellen, die

mehrere erhalten beobachtbare Anforderungen in einer for-Schleife Angular2 Django

Anzahl der Antworten 1 Antworten
Ich versuche, mehrere get-Anforderungen mit Angular2 in Django/python. Ich bin in der Lage, führen Sie eine API-Anfrage und erhalten Sie eine Liste von Benutzern finden der id des aktuellen Benutzers. Ich führen Sie dann eine .flatMap Vorgang,

Wie Sie wieder neue Observable(function(observer) { ... mit RxJS v5?

Anzahl der Antworten 1 Antworten
Ich versuche, ersetzen, all die Versprechungen, die meine Funktionen zurück, die mit Observablen. Aus diesem post habe ich gelernt, dass ich sollte nicht mehr verwendet werden "neue Beobachten" Beobachtbar ist.forkJoin und array-argument Was ist der RxJS v5-syntax

RxJS Beobachtbaren Rückgabe-array, führen Sie eine andere Funktion, die mit jedem array-iteration

Anzahl der Antworten 1 Antworten
Habe ich eine Funktion getNews(), die im Grunde gibt eckige http.get-Anforderung. Ergebnis der Anfrage ist array von IDS. Ich möchte eine Iteration durch das array, die ich bekam, und führen Sie einen weiteren http.get-Anfrage (Funktion getItem(id)), die

rxjs/Abonnement hat keine exportiert Mitglied 'Abonnement'

Anzahl der Antworten 3 Antworten
Ich aktualisierte mein Winkel-Projekt, und alle meine Abhängigkeiten auf die neueste version. Ohne zu viel Mühe löste ich die meisten dependecy Fragen, aber ich bin immer noch sitzt auf RxJs. Hier ist mein Paket.json: "dependencies": { "@angular-devkit/build-angular":

Angular2. Wie kann ich überprüfen, ob eine beobachtbare abgeschlossen ist?

Anzahl der Antworten 5 Antworten
Meiner Seite gibt es eine Schaltfläche, dass ein Bericht erstellt wird. Dieser Bericht muss die Daten, die geladen wird mit einem http-Aufruf an einen rest-Endpunkt, wenn die Seite geladen wird, aber ich habe keine Garantie, dass Sie

Die richtige Art, abonnieren valueChanges im Winkel 2

Anzahl der Antworten 3 Antworten
Ich habe schon hantieren mit reaktiven Formen und valueChanges Abonnement in den Winkel-2. Ich don;t Recht bekommen, warum eine bestimmte form der Anmeldung scheint nicht möglich. this.form.get('name').valueChanges /* <- doesn't work */ .do(changes => { console.log('name has

Angular2. Anzeigen http-Antwort zu konkreten Objekt-Instanz

Anzahl der Antworten 3 Antworten
Gemeinsamen Ansatz zur Verarbeitung von http-response sieht so aus: return this._http.get(url) .map((res: Response) => res.json()); bietet Ihnen eine Observable<Object> wo Object dynamisch erstellt Art von json-de-Serialisierung. Dann können Sie dieses Ergebnis in *ngFor="let item of result |

Eckige 2 - Countdown-timer

Anzahl der Antworten 2 Antworten
Ich bin bereit zu tun, einen countdown-timer in den Winkel-2, die aus 60 (ich.e 59, 58,57, etc...) Dafür habe ich die folgenden: constructor(){ Observable.timer(0,1000).subscribe(timer=>{ this.counter = timer; }); } Oben, tickt jede Sekunde, die ist in Ordnung;

Was ist das Rohr, das in rxJS

Anzahl der Antworten 1 Antworten
Ich glaube, ich habe die base-Konzept, aber es gibt einige Unklarheiten So im Allgemeinen das ist, wie ich mit einer observable: observable.subscribe(x => { }) Wenn ich die Daten filtern möchten, kann ich dieses verwenden: import {

RXJS wenn mit beobachtbaren bedingten

Anzahl der Antworten 2 Antworten
Möchte ich Rx.Observable.if Ausführung von einem von zwei observablen sollte eine bedingte beobachtbare beheben, der zu true oder false. Was ich erreichen wollen würde wie folgt Aussehen: Rx.Observable.if(conditionalObservable.map(x => x.length > 0), firstObservable, secondObservable).subscribe() Wenn conditionalObservable sendet