Tag: rxjs5
Die 5. version des reactive extensions für die javascript.
Wie zu beobachten-Objekt ändert sich mit rxjs 5
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
Wie zu fangen Fehler in RxJS 5.5
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() ||
shareReplay in RxJS 5
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 der "flatmap" Betreiber bedingt ? (Winkel 2/rxjs)
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
Mit RxJs und Winkel 2 im Hinblick auf den Umgang mit server-sent events
3 Antworten
Ich versuche, Anzeige von server-sent-events emittierten Werte in eine eckige 2 /RxJs app. Backend versendet regelmäßig an einzelnen strings an den client über das server-sent-events. Ich bin mir nicht sicher, wie man mit der abgerufene Werte für
Kann nicht finden `combineLatest` in RxJS 5.0
5 Antworten
Den folgenden code verursacht mir eine Observable.combineLatest is not a function mit RxJS 5.0: let Observable = require('rxjs/Observable.js').Observable; import 'rxjs/add/operator/combineLatest'; Observable .combineLatest([player, spaceShip], (shotEvents, spaceShip) => ({ x: spaceShip ? spaceShip.x : board.canvas.width /2, timestamp: shotEvents.timestamp }))
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 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
Beobachtbare Fehler mit Angular2 beta.12 und RxJs 5 beta.3
3 Antworten
Hallo, Ich bin mit Angular2 beta 12 läuft in VS2015. Wenn ich update auf rxjs von 5.0.0-beta.2 zu beta.3 ich habe auch eine Reihe von Ausnahmen, in der Regel in Bezug auf mein Versprechen. E. g. Eigenschaft
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
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
Verkettung Observablen in RxJS
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) => {
Richtige Weg, um ein upgrade RxJS auf neueste version?
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.
Angular2 Beobachtbaren Filter
1 Antworten
Ich würde gerne filter eine erkennbare, aber bin immer unerwartete Ergebnisse. Ich bin mit der folgenden import-Anweisungen: import {Observable} from 'rxjs/Observable'; import 'rxjs/add/observable/of'; In diesem Beispiel wird nichts: Observable.of([0, 1, 2, 3, 4, 5]) .filter((x: any) =>
RxJS Map-array zu beobachten und zurück zu Ebene-Objekt im array
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,
RxJs und Typoskript. TS2307: Cannot find module '@reactivex/rxjs'
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: Wie abonnieren Http.post beobachtbaren im inneren einen Dienst und eine Komponente, richtig?
2 Antworten
Für eine JWT-Authentifizierung, mache ich eine post-Anfrage, um die token mit dem neuen Http Modul arbeitet mit Observablen jetzt. Habe ich eine einfache Login Komponente anzeigen des Formulars: @Component({ selector: 'my-login', template: `<form (submit)="submitForm($event)"> <input [(ngModel)]="cred.username" type="text"
Warten auf eine beobachtbare zu beenden
1 Antworten
Habe ich eine Methode, die muss warten, bis ein beobachtbares zu beenden. Ich weiß beobachtbar sind ideal für die Rückgabe einzelner Stücke von Daten über die Zeit, aber ich muss wissen, wenn diese beobachtbar ist komplett fertig
Was ist das Rohr, das in rxJS
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: Beobachtbar Ist.create() vs. Beobachten.aus()
4 Antworten
Was ist der Unterschied zwischen diesen beiden? return Observable.create(function(observer) { if (array) observer.next(); else observer.next(null); observer.complete(); }); und return Observable.from( array ? : null ); Dachte ich, es könnte die gleiche sein, aber nicht die gleiche
import .der (die) für Beobachtbare in Typoskript
2 Antworten
Ich bin mit diesem großen repo für meine eckige 2-test-Projekt (Typoskript) - https://github.com/qdouble/angular-webpack2-starter. Und ich zu Beobachten.(..). Wenn ich versuche zu importieren: import { Observable } from "rxjs/Observable"; import { of } from 'rxjs/observable/of'; Bekomme ich: Eigenschaft
ObjectUnsubscribedError, wenn Sie versuchen zu verhindern, dass zweimal abonnieren
2 Antworten
Ich habe einen Dienst und eine Komponente, die verwendet wird: PagesService PagesListComponent In der PagesService ich habe ein array von Pages. Ich informieren, änderungen in dem array über eine BehaviorSubject die beiden von Ihnen abonniert sind. Den
Beste Art und Weise zu "reduzieren" ein array innerhalb einer Beobachtbaren RxJS
4 Antworten
Mein backend Häufig gibt Daten als ein array innerhalb einer RxJS 5 Beobachtbaren (ich bin mit Winkel 2). Oft finde ich mich wollen, um Prozess der array-Elemente einzeln mit RxJS Betreiber und ich tun dies mit dem
Wie zu Stoppen zu beobachten.timer in Angular2
2 Antworten
Ich die Umsetzung der folgenden Funktionen in Angular2 Komponente: export class MypageEditComponent { ngOnInit() { this.timer = Observable.timer(100, 100); this.timer.subscribe(t => { this.setFormData(); } private setFormData() { this.editUserAcountType = this.authStore.registerInfo.account_type; this.editAddress = this.authStore.registerInfo.email; this.editUserName = this.authStore.registerInfo.username; }
Was sind die Semantik von verschiedenen RxJS Themen?
1 Antworten
Dokumentation zum Thema ist spärlich und es ist schwer zu entdecken, ein "entry-point" gibt. InformationsquelleAutor Ivan Kleshnin | 2016-01-18
RxJS: takeUntil() Winkel-Komponente ngOnDestroy()
4 Antworten
tl;dr: im Grunde will ich heiraten Eckig ist ngOnDestroy mit der Rxjs takeUntil() Betreiber. -- ist das möglich? Habe ich eine Eckige Komponente, öffnet mehrere Rxjs Abonnements. Diese müssen geschlossen werden, wenn das Bauteil zerstört wird. Eine
Einfacher Weg, um den aktuellen Wert einer BehaviorSubject mit rxjs5
1 Antworten
Zuvor in rxjs4 es war eine Methode, die in der BehaviorSubject genannt: getValue() (doc hier). Diese Methode existiert nicht mehr in rxjs5. Also die einzige Lösung, die ich gefunden, um den Wert eines BehaviorSubject war: let value;
Eckige 2 - Sortieren Sie die Liste von Beobachtbaren
1 Antworten
Was ist der beste Weg, um sort eine Liste der Elemente aus einer Observable und noch in der Lage zu verwenden, die async pipe? (Ich habe gelesen, dass die benutzerdefinierte Sortierung des Rohres ist nicht wirklich effizient.)
rxjs 5 publishReplay refCount
2 Antworten
Ich kann nicht herausfinden, wie publishReplay().refCount() funktioniert. Beispielsweise (https://jsfiddle.net/7o3a45L1/): var source = Rx.Observable.create(observer => { console.log("call"); //expensive http request observer.next(5); }).publishReplay().refCount(); subscription1 = source.subscribe({next: (v) => console.log('observerA: ' + v)}); subscription1.unsubscribe(); console.log(""); subscription2 = source.subscribe({next: (v) =>
Wie zu verwenden RxJs distinctUntilChanged?
2 Antworten
Ich bin erste Schritte mit RxJs (mit der v5 beta), aber irgendwie kann ich nicht herausfinden, wie die Arbeit mit distinctUntilChanged. Die Ausgabe aus dem code unten, wenn ich es im babel-Knoten ist [ 'a', 1 ]
Rxjs 5 - Einfach Ajax-Request
2 Antworten
Ich versuche, den Wert aus einer einfachen ajax-request, aber ich verstehe nicht, wie das zu tun. Hier ist der code: Rx.Observable .ajax({ url: 'https://jsonplaceholder.typicode.com/posts', method: 'GET', responseType: 'json' }) .subscribe(function(data) { return data.response; }); Habe ich überall
Wie implementiert man ein draggable div in den Winkel-2 mit Rx
4 Antworten
Ich habe versucht, ein draggable div arbeiten mit Winkel-2. Ich bin mit dieses Beispiel aus dem angular2-Beispiele repo als Ausgangspunkt eigentlich nur die Anpassung der code-Rechnung für die Entfernung der toRx() Methode. Der code funktioniert, aber nicht
Wie das zu erreichen ist eine debounce-service am Eingang keyup-Ereignis in angular2 mit rxjs
4 Antworten
Ich versuche zu rufen, um einen Dienst, der auf Eingabe Schlüssel-up-Ereignis. Den HTML - <input placeholder="enter name" (keyup)='onKeyUp($event)'> Unten ist die onKeyUp() Funktion onKeyUp(event) { let observable = Observable.fromEvent(event.target, 'keyup') .map(value => event.target.value) .debounceTime(1000) .distinctUntilChanged() .flatMap((search) =>
Nicht finden können Modul 'rxjs/Thema/BehaviorSubject'
1 Antworten
Ich bin mit Angular 2. Wenn ich diese beiden, mein Programm läuft gut: import { BehaviorSubject } from 'rxjs/Rx'; import { BehaviorSubject } from 'rxjs'; Jedoch versuche ich den folgenden Weg verwenden: import { BehaviorSubject } from
Wie funktioniert die RxJs 5 teilen () - operator arbeiten?
2 Antworten
Seine nicht 100% klar für mich, wie der RxJs 5 share() - operator funktioniert, sehen Sie hier die neueste docs. Jsbin für die Frage hier. Ist, wenn ich eine observable mit einer Reihe von 0 bis 2
Wie man eine Observable erhält, um Daten sofort und alle 5 Sekunden danach zurückzugeben
4 Antworten
Ich möchte erstellen Sie eine beobachtbare Daten zurückgibt, die von einem webapi. Ich möchte es zurückgeben, dass die Daten sofort, und eine Umfrage der API alle 10 Sekunden. Der code unten zeigt, ich bin mit der Intervall-Methode.
Wie abonniere ich den Event Emitter einmal?
2 Antworten
//Part of service public someEvent: EventEmitter<number> = new EventEmitter(); .... //Component @Component({ selector: 'some-component', template: `...` }) export class SomeComponent { constructor(public service: Service) { this.service.someEvent.subscribe((x) => { //Do something }); } } SomeComponent wird angezeigt, in
Wann sollte asObservable () in rxjs verwendet werden?
1 Antworten
Frage ich mich, was ist die Verwendung von: https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/asobservable.md als pro docs: (Beobachtbaren): Eine beobachtbare Sequenz verbirgt die Identität der Quell-Sequenz. aber warum würden Sie brauchen, um zu verbergen die Reihenfolge? hinsichtlich Sean InformationsquelleAutor der Frage born2net
Wie kann das Ergebnis eines Angular Http Netzwerkaufrufs in RxJs 5 korrekt geteilt werden?
21 Antworten
Durch die Verwendung von Http ist, rufen wir eine Methode, die eine Netzwerk-Anruf ist, und gibt einen http beobachtbar: getCustomer() { return this.http.get('/someUrl').map(res => res.json()); } Wenn wir dies beobachten, und fügen Sie mehrere Abonnenten: let network$
Verkettung von Observablen in RxJS
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) => {
Angular 2 mit RxJS - take (1) vs erste ()
3 Antworten
Fand ich einige Umsetzung der Auth-Wachen, die verwendet take(1). Auf mein Projekt, die ich verwendet first() zu befriedigen meine Bedürfnisse. Funktioniert es auf dieselbe Weise? Oder einer von Ihnen könnte Vorteile haben oder so. import 'rxjs/add/operator/map'; import
Wie erhält man den aktuellen Wert des State-Objekts mit @ ngrx / store?
6 Antworten
Mein service Klasse, vor Aufruf eines web service, benötigt man eine Eigenschaft namens dataForUpdate von meinem Zustand. Derzeit mache ich es so: constructor ( public _store: Store<AppState>, public _APIService:APIService) { const store$ = this._store.select ('StateReducer'); .../... let
Angular 2 Router Auflösung mit Observable
1 Antworten
Nach dem release von Angular 2 RC.5 es wurde eingeführt router beheben. Hier demonstrierte Beispiel mit Versprechen, wie Sie das gleiche tun, wenn ich die Anfrage an den server mit Beobachten? suchen.service.ts ... searchFields(id: number) { return
Beobachtbar Abschließend auf Abonnieren
1 Antworten
Laut dieses artcleonComplete und onError Funktion der subscribe schließen sich gegenseitig aus. Bedeutung onError oder onComplete events Feuer bis in meine subscribe. Ich habe ein Logik-block, der ausgeführt werden muss, ob ich eine Fehlermeldung erhalte, oder ich
Hot and Cold Observables: Gibt es "heiße" und "kalte" Operatoren?
4 Antworten
Ich überprüfte die folgende Frage ALSO: Was sind die warmen und Kalten observablen? Zusammenfassen: einem kalten beobachtbaren emittiert seine Werte, wenn es einen Beobachter zu konsumieren, d.h., die Reihenfolge der Werte erhalten Sie von Beobachtern ist unabhängig
Wie kann ich diesen "Subject observable observable" -Fehler in TypeScript 2.4 und RxJS 5.x umgehen?
7 Antworten
Wenn ich kompilieren möchte, bekomme ich folgende compiler-Fehlermeldung in der RxJS Erklärung-Dateien: node_modules/rxjs/Subject.d.ts(16,22): error TS2415: Class 'Subject<T>' incorrectly extends base class 'Observable<T>'. Types of property 'lift' are incompatible. Type '<R>(operator: Operator<T, R>) => Observable<T>' is not assignable
Angular2 + http in einem Intervall
4 Antworten
Ich bin ganz neu mit Winkel-und rxjs. Ich bin versucht, zu erstellen eine angular2 app, die ruft einige Daten aus staticly serviert-text-Datei(Lokal auf server), die möchte ich abrufen und anzeigen zu Datamodel mit Angular2 http Anbieter und
Wie gibt man einen Wert von der Funktion zurück, die ein beobachtbares Abonnement enthält?
4 Antworten
Ich nicht wissen, wie zu extrahieren Wert aus Beobachtbaren Rückgabe der Funktion, in der Beobachtbaren vorhanden ist. Ich benötige nur einen Wert aus, um zurückgegeben werden, sonst nichts. Aktuelle version die funktioniert function getValueFromObservable() { this.store.subscribe( (data:any)