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.
Die Eigenschaft 'catch' existiert nicht für den Typ 'Observable & lt; any & gt;'
2 Antworten
Auf dem Winkel 2 Dokumentations-Seite für die Verwendung der Http-Dienst ist ein Beispiel. getHeroes (): Observable<Stuff> { return this.http.get(this.url) .map(this.extractData) .catch(this.handleError); } Ich geklont angular2-webpack-starter Projekt und ergänzt den oben genannten code selbst. Ich importiert Observable mit
Redux & amp; RxJS, irgendwelche Ähnlichkeiten?
5 Antworten
Ich weiß Redux ist eine bessere "Umsetzung" der Fluss, oder besser zu sagen, dass es ein redesign, um die Dinge zu vereinfachen (application state management). Ich habe gehört, eine Menge über reaktive Programmierung (RxJS), aber ich habe
Observable type error: Kann die Eigenschaft von undefined nicht lesen
3 Antworten
Eckig 2-Anwendung, bekomme ich die Fehlermeldung: cannot read property 'name' of undefined". Dies ist eine sehr einfache Komponente, nur versuchen, Holen Sie sich ein absolutes minimum, um hier zu arbeiten. Es traf meine API-controller (seltsamerweise mehrere Male),
Node.js Streams vs Observables
1 Antworten
Nach dem lernen über Observablenich finde Sie Recht ähnlich Node.js streams. Beide haben einen Mechanismus, der Mitteilung an die Verbraucher, Wann immer neue Daten eintreffen, tritt ein Fehler auf oder es gibt keine Daten mehr (EOF). Ich
Versprechen gegen beobachtbar
16 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 nutzen? InformationsquelleAutor der Frage Rohit | 2016-05-21
Wie man beobachtbar von subscribe zurückgibt
3 Antworten
Ich versuche, um eine beobachtbare wenn ich einen bestimmten Wert in einen Abonnenten, aber ich scheitere kläglich. Dies ist der code: canActivate(route: ActivatedRouteSnapshot, state: RouterStateSnapshot):Observable<boolean> { //get route to be activated this.routeToActivate = route.routeConfig.path; //get user access
Der beste Weg, Observable aus Rxjs zu importieren
3 Antworten
In meinem Winkel 2 app habe ich einen Dienst, der verwendet die Observable Klasse aus der rxjs Bibliothek. import { Observable } from 'rxjs'; Im moment bin ich nur mit Observable so, dass ich das toPromise() Funktion.
RxJS: Wie würde ich ein Observable "manuell" updaten?
2 Antworten
Ich glaube ich muss etwas grundlegendes Missverständnis, weil in meinem Kopf diese sollten die grundlegenden Argumente für eine Bemerkenswerte, aber für das Leben meines ich kann nicht herausfinden, wie man es von den docs. Im Grunde, ich
Property 'filter' existiert nicht für den Typ 'Observable & lt; Event & gt;'
6 Antworten
Hallo, ich bin mit Winkel-2 endgültig mit dem router 3.0. Ich möchte zum filtern der Ereignisse, die emittiert werden von this.router.events Was ich tun will : import 'rxjs/operator/filter'; //... this.router.events .filter((event:Event) => event instanceof NavigationEnd) .subscribe(x =>
Angular 2 - Behandlung mehrerer Abonnements auf einer einzigen Beobachtungsstelle
1 Antworten
Arbeite ich an einer Winkel-2-app und benötigen Sie einige Hinweise zum Umgang mit Authentifizierungsfehler sauber. Mein end-Ziel ist, die zentrale Authentifizierung verarbeiten von Fehlern (insbesondere 401 und 403) für jeden Http Anfrage. Fand ich diese Frage super
Angular2 - Bindung der UI an beobachtbare Eigenschaft
2 Antworten
Ich bin mit Winkel-2 Witz rxjs zu beobachten. Erstellt habe ich dieses interface: interface IGame { name: string; description: string; } Verwende ich es als eine beobachtbare und vorbei, es als Eingabe für die Benutzeroberfläche: @Input() public
Angular 2 Observable mit mehreren Abonnenten
4 Antworten
Habe ich eine eckige 2-service, abrufen von Daten von einer API dieser service hat 3 Abonnenten (definiert in Komponenten) jeder etwas anderes mit den Daten (unterschiedliche Diagramme) Ich bin zu bemerken, dass ich mache drei GET-Anfragen an
Angular 2 - Liefert Daten direkt von einem Observable zurück
2 Antworten
Ich habe schlug meinen Kopf gegen diesen einen Versuch, es herauszufinden, und kein Betrag der Dokumentation habe ich in der Lage zu Lesen, hat mir eine Antwort auf meine Frage. Habe ich ein service sprechen direkt an
Wie kann ich eine RxJS Observable-Sequenz darauf warten lassen, dass eine andere abgeschlossen wird, bevor sie ausgesendet wird?
5 Antworten
Sagen, ich habe eine Beobachtbare, etwa so: var one = someObservable.take(1); one.subscribe(function(){ /* do something */ }); Dann habe ich einen zweiten beobachten: var two = someOtherObservable.take(1); Nun, ich abonnieren möchten twoaber ich wollen, stellen Sie sicher,
BehaviorSubject vs Observable?
4 Antworten
Ich bin auf der Suche in Eckigen RxJs Muster und ich verstehe nicht den Unterschied zwischen einem BehaviorSubject und ein Observable. Aus meinem Verständnis, eine BehaviorSubject ist ein Wert, der im Laufe der Zeit ändern (können abonniert
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$
Beobachtbar & lt; {} & gt; nicht dem Typ Observable & lt; SomeType [] & gt;
5 Antworten
Ich Lerne Angular2 und Typoskript. Ich arbeite durch das Heroes-tutorial auf eckig.io, aber wenn es um ein Projekt, das ich bin, der Umwandlung von ASP.Net. Ich habe laufen in ein problem, von dem ich denke, ist aufgrund
Verwenden eines Arrays aus dem Observable Object mit ngFor und Async Pipe Angular 2
1 Antworten
Ich versuche zu verstehen, wie Observablen in den Winkel-2. Ich habe diesen service: import {Injectable, EventEmitter, ViewChild} from '@angular/core'; import {Observable} from "rxjs/Observable"; import {Subject} from "rxjs/Subject"; import {BehaviorSubject} from "rxjs/Rx"; import {Availabilities} from './availabilities-interface' @Injectable() export
RxJS Sequenz äquivalent zu versprechen.
2 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
Wie erstellt man ein Observable aus statischen Daten ähnlich wie http in Angular?
4 Antworten
Bin ich mit einem service, der diese Methode: export class TestModelService { public testModel: TestModel; constructor( @Inject(Http) public http: Http) { } public fetchModel(uuid: string = undefined): Observable<string> { if(!uuid) { //return Observable of JSON.stringify(new TestModel()); }
SwitchMap vs MergeMap im #ngrx-Beispiel
4 Antworten
Unten ist der code von der Ngrx Beispiel: https://github.com/ngrx/example-app/blob/master/src/effects/book.ts Meine Frage ist warum in der ersten @ - Effekt hat, nutzt es switchMap während die anderen nutzen mergeMap. Ist das, weil die ersten @ - Effekt ist
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) => {
Wie kann ich auf einem Rx Observable "erwarten"?
3 Antworten
Ich würde gerne in der Lage sein, zu warten auf eine beobachtbare, z.B. const source = Rx.Observable.create(/* ... */) //... await source; Einem naiven Versuch, die Ergebnisse in der await-Lösung sofort und nicht blockierende Ausführung Bearbeiten: Der
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
Angular 2: Warum SwitchMap beim Abrufen von Routenparametern verwenden?
1 Antworten
Bin ich beim Lesen des Winkel-Guide über Routing & Navigation. Verwenden Sie diesen code für das abrufen der router param 'id' und verwenden Sie es, um ein held mit der service service: ngOnInit() { this.route.params .switchMap((params: Params)
Rxjs Flatmap fehlt
5 Antworten
Ich versuche, Kette mehrere rx.js observablen und übergeben Sie die Daten. Flatmap sollte der Einbau Betreiber aber mit einem import import { Observable } from 'rxjs/Observable'; es nicht gefunden: Error TS2339: Property 'flatmap' does not exist on
Wie kann ich ein Drop-down-Menü bei Klick-Outs schließen?
16 Antworten
Möchte ich schließen, meine login-dropdown-Menü, wenn der Benutzer auf eine beliebige Stelle außerhalb des dropdown -, und ich möchte zu tun, dass mit Angular2 und mit der Angular2 "Ansatz"... Ich habe implementiert eine Lösung, aber ich wirklich
Warte auf eine asynchrone Operation in onNext von RxJS Observable
3 Antworten
Ich habe eine RxJS Sequenz, die verbraucht wird, in der normalen Art und Weise... Jedoch in der beobachtbaren 'onNext' handler, einige der Vorgänge synchron abgeschlossen, aber andere erfordern asynchrone Rückrufe, müssen abgewartet werden, bevor die Verarbeitung der
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
Angular / RxJs Wann sollte ich mich von "Subscription" abmelden?
12 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
RxJs Beobachtbar von vs von
3 Antworten
Ist der einzige Unterschied zwischen Observable.of und Observable.from die Argumente format? Wie die Function.prototype.call und Function.prototype.apply? Observable.of(1,2,3).subscribe(() => {}) Observable.from([1,2,3]).subscribe(() => {}) InformationsquelleAutor der Frage xiaoke | 2017-03-09
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
Angular 2 2.0.0-rc.1 Property 'map' existiert nicht für den Typ 'Observable & lt; Response & gt;' nicht das gleiche wie Problembericht
16 Antworten
während dies sieht aus wie gleiche Problem wie Winkel-2 beta.17: Eigenschaft 'anzeigen' nicht vorhanden ist auf dem Typ 'Beobachtbare<Antwort>' dies ist eine neue version und diese Lösungen nicht für diese neue version freigegeben Ich habe das update
Ist es notwendig, sich von Observablen, die mit Http-Methoden erstellt wurden, abzumelden?
3 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()); ... InformationsquelleAutor der Frage born2net | 2016-01-27
rxjs wie emittierst du einen einzelnen Wert
2 Antworten
Ich würde gerne emittieren einen einzelnen Wert. Gemäß dieser postsollte 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? InformationsquelleAutor
Angular HTTP GET mit TypeScript-Fehler http.get (...) .map ist keine Funktion in [null]
11 Antworten
Ich habe ein problem mit HTTP in Eckig. Ich will nur GET eine JSON Liste und zeigen Sie in der Ansicht. Service-Klasse import {Injectable} from "angular2/core"; import {Hall} from "./hall"; import {Http} from "angular2/http"; @Injectable() export class
Wie man Daten von beobachtbar in angular2 erhält
3 Antworten
Ich versuche, drucken Sie das Ergebnis der http Anruf in Angular mit rxjs Betrachten Sie den folgenden code import { Component, Injectable, OnInit } from '@angular/core'; import { Http, HTTP_PROVIDERS } from '@angular/http'; import 'rxjs/Rx'; @Injectable() class
Reaktive Programmierung - RxJS vs EventEmitter in Node.js
3 Antworten
Kürzlich habe ich begann, mich bei RxJS und RxJava(von Netflix) - Bibliotheken, die auf das Konzept der Reaktiven Programmierung. Node.js arbeiten auf der Grundlage von event-loops, die bietet Ihnen alle arsenal für asynchrone Programmierung und die anschließende
Umgang mit Aktualisierungstoken mit rxjs
3 Antworten
Seit ich angefangen habe, mit angular2 ich habe meine setup-Dienstleistungen zur Rückkehr Beobachten von T. In den service hätte ich mir die anzeigen () - Aufruf, und Komponenten bei der Nutzung dieser Dienste würde halt subscribe() die
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
Anwendungsfall des beobachtbaren Operators .do () (rxjs)
1 Antworten
Rahmen : Baue ich eine eckige 2-app (mit einer FB-API). Ich bin mit dem AngularFire Modul. Ich Frage mich, wie ich mischen die canActivate Methode mit der AngularFire auth Beobachten, und ich fand dieser Beitrag. Die Antwort
Wie erhält man den aktuellen Wert von RxJS Subject oder Observable?
5 Antworten
Habe ich eine Eckige 2-service: import {Storage} from './storage'; import {Injectable} from 'angular2/core'; import {Subject} from 'rxjs/Subject'; @Injectable() export class SessionStorage extends Storage { private _isLoggedInSource = new Subject<boolean>(); isLoggedIn = this._isLoggedInSource.asObservable(); constructor() { super('session'); } setIsLoggedIn(value:
Angular 4 Interceptor retry requests nach Token-Aktualisierung
7 Antworten
Hallo, ich bin versucht, herauszufinden, wie die Umsetzung der neuen Winkel-Abfangjäger und Griff 401 unauthorized Fehler durch eine Aktualisierung des Tokens und wiederholen Sie die Anforderung. Dies ist das Handbuch habe ich bisher Folgendes: https://ryanchenkie.com/angular-authentication-using-the-http-client-and-http-interceptors Ich bin
Veröffentlichen Sie den letzten Wert einer Observablen
1 Antworten
Habe ich eine heiße beobachtbar ist (ein Thema, in diesem Fall): var subject = new Rx.Subject(); Ich möchte erstellen Sie eine weitere beobachten, dass jedes mal, wenn eine neue Abonnements wird sofort feuert aus den letzten Wert,
rxjs / Subject.d.ts Fehler: Klasse 'Betreff & lt; T & gt;' erweitert Basisklasse "Observable & lt; T & gt;"
15 Antworten
Ich extrahierten Probe template-code aus https://github.com/gopinav/Angular-2-Tutorials und hat unten zwei Schritte, um loszulegen - npm install //worked fine and created node_modules folder with all dependencies npm start //nicht mit unter Fehler- node_modules/rxjs/Thema.d....ts(16,22): Fehler TS2415: Class 'Betreff' falsch
RxJS mehrere Abonnements für Observable?
5 Antworten
Erstelle ich meine eigenen beobachten und abonniert haben zwei Funktionen. Ich würde erwarten, dass beide Funktionen ausgeführt, die für jedes element in der Sequenz aber nur das Letzte ist. let observer = null const notificationArrayStream = Rx.Observable.create(function
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)
Angular2 http.get (), map (), subscribe () und beobachtbares Muster - Grundverständnis
3 Antworten
Nun, ich habe die erste Seite, wo ich drei links. Sobald Sie klicken Sie auf die Letzte "friends" - link, geeignete Freunde Komponente wird eingeleitet. Dort, Ich möchte zu Holen/get Liste meiner Freunde strored zu Freunden.json-Datei. Bis
Wie erhält man Blob-Antworten mit Angulars 2+ @ angular / http-Modul?
3 Antworten
Bin ich versucht, ein pdf-download in eine eckige 2-app... dieser code funktioniert: var reportPost = 'variable=lsdkjf'; var xhr = new XMLHttpRequest(); xhr.open("POST", "http://localhost/a2/pdf.php", true); xhr.responseType = 'blob'; xhr.setRequestHeader("Content-type", "application/x-www-form-urlencoded"); xhr.onreadystatechange = function() {//Call a function when the
Property 'toPromise' existiert nicht für den Typ 'Observable & lt; Response & gt;'
5 Antworten
import { Headers, Http } from '@angular/http'; @Injectable() export class PublisherService{ private publishersUrl = 'app/publisher'; constructor(private http: Http) { } getPublishers(): Promise<Publisher>{ return this.http.get(this.publishersUrl) .toPromise() .then(response => response.json().data) .catch(this.handleError); } } Bin ich immer diese Fehlermeldung: Eigenschaft