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.

rxjs zu beobachten.von(Objekt) zurückgibt, {"_isScalar": "", "value": {}, "scheduler": "" } anstatt den Wert

Anzahl der Antworten 1 Antworten
Ich bin ziemlich neu in rxjs. Ich habe versucht, zu erstellen eine Funktion, die führt einen Winkel-2 http-request wie: syncFromApi$() { //create Headers ... let ob$ = this.http.post( CONFIG_APP.apiEndpoint + '/sync/app', '', { headers: headers } )

Holen Sie sich den aktuellen Wert des Subjekts.asObservable() in Eckigen service

Anzahl der Antworten 2 Antworten
Möchte ich mal ein einfaches Umschalten innerhalb einer Angular2 service. Deshalb brauche ich den aktuellen Wert einer Subject ich beachten (siehe unten). import {Injectable} from 'angular2/core'; import {Subject} from 'rxjs/Subject'; @Injectable() export class SettingsService { private _panelOpened

Winkel 4, konvertieren http-Antwort-observable-Objekt zu beobachten

Anzahl der Antworten 3 Antworten
Ich bin neu in die Konzepte von observablen und brauchen etwas Hilfe mit der Konvertierung. Ich habe ein service, das gibt ein Observable<Response> aus einer Http-Anfrage, aber ich brauche, um zu konvertieren, es nicht ein Observable<PriceTag> Sie

RxJS: Beobachtbar Ist.create() vs. Beobachten.aus()

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

Wie erstellen RxJS Thema im Winkel 2?

Anzahl der Antworten 2 Antworten
Ich bin in der Lage, erstellen Sie eine Observable, die in meinem Winkel-Bauteil in unten genannten Weg ... ... import { Observable } from 'rxjs/Observable'; .. ... let observable = new Observable( function subscribe(observer) { observer.next(1); observer.next(2);

Wie löse ich eine Beobachtbare innerhalb eines anderen Beobachten? - rxjs

Anzahl der Antworten 3 Antworten
Ich habe eine Observable in dem ich verbrauchen die anderen zu beobachten, aber der 2. Observable ich kann nicht zu beheben. Hier ist der code: return Observable.fromPromise(axios(config)) .map(res => { return { accessToken: res.data.access_token, refreshToken: res.data.refresh_token }

flatMap fehlen nach Upgrade auf RC-6 und RxJS Beta 11

Anzahl der Antworten 2 Antworten
Nach dem Update auf RC6 und [email protected] ich scheinen zu fehlen ein paar Erweiterungen vom beobachteten Objekt. flatMap-operator ist Weg, mergeMap ist auch nicht hier. Ich sehe nur ein paar Betreiber nun. Keine Ahnung, was mir fehlt?

Eckige "hat keine exportiert Mitglied 'Beobachtbar'"

Anzahl der Antworten 13 Antworten
Typoskript-code: import { Injectable } from '@angular/core'; import { Observable } from 'rxjs/Observable'; import { of } from 'rxjs/observable/of'; import { Hero } from './hero'; import { HEROES } from './mock-heroes'; @Injectable({ providedIn: 'root' }) export class

Wie um die Karte Response-Objekt zurückgegeben, die vom Http-Service um ein Typoskript Objekte mit Beobachtbar Map-Funktion in Angular2

Anzahl der Antworten 2 Antworten
Hallo, ich habe erstellt eine angular2 Dienst, dessen Aufgabe ist der Aufruf einer webapi gibt Daten in ein json-Objekt-Struktur wie folgt: //Result of the webapi service call. { "Total":11, "Data":[{"Id":1,"Name":"A","StartDate":"2016-01-01T00:00:00"}, {"Id":2,"Name":"B","StartDate":"2016-02-01T00:00:00"}] } Hier ist mein angular2 service.

Angular2 Uhr für die 302-Weiterleitung beim abrufen der Ressource

Anzahl der Antworten 2 Antworten
Habe ich eine Anforderung zu ziehen Sie ein paar Ressourcen einer anderen Domäne statt, durch meine Firma. Ich möchte zu ziehen gesicherten HTML-Inhalt mit GET-Anfragen. Wenn ein Benutzer angemeldet ist aus der Anwendung der angeforderte Inhalt zurück

Winkel-2: Verwendung von Beobachtbaren filter

Anzahl der Antworten 2 Antworten
Ich habe einen Dienst, der Aufrufe der API wie diese: return this._http .post(appSettings.apiUrl + 'SomeController/SomeAction', params, {withCredentials: true, headers: this.headers}) .timeoutWith(appSettings.maxTimeHttpCalls, Observable.defer(() => Observable.throw(this._feedbackService.timeout()))) .map((response: Response) => response.json().data); Nun möchte ich einen filter implementieren, der Funktion, der

Mit RxJS mit Typoskript

Anzahl der Antworten 6 Antworten
Ich habe ein problem, versucht die RxJS mit Typoskript und Node.js. Ich bin mit NPM, und ich habe rxjs-es version 5. Ich bin auch mit Testungen, und ich habe beide es6-shim und rx.all: { "ambientDependencies": { "es6-shim":

Wie zu erwarten innerhalb RxJS subscribe-Methode

Anzahl der Antworten 6 Antworten
Innerhalb eines RxJS Thema abonnieren Rückruf, ich will await auf eine async Funktion. Im folgenden ist ein Codebeispiel, die das Typoskript transpiler beschwert sich über zu sagen: Error:(131, 21) TS2304:Cannot find-name 'erwarten'. async ngOnInit() { this.subscriber =

Angular2 Beobachtbaren Timer-Zustand

Anzahl der Antworten 3 Antworten
Habe ich einen timer: initiateTimer() { if (this.timerSub) this.destroyTimer(); let timer = TimerObservable.create(0, 1000); this.timerSub = timer.subscribe(t => { this.secondTicks = t }); } Wie sollte ich hinzufügen, dass die Bedingung, um nach 60 Minuten präsentieren ein

Angular2 so aktualisieren Sie ein Element in eine observable-collection

Anzahl der Antworten 2 Antworten
Update, kurz: Ich bin auf der Suche nach den Gegenwert von etwas wie das zu tun, aber für eine Beobachtbare eher als ein normales array: var i = this.customers.findIndex(customer => customer._id === id); ~i && this.customers[i] =

Wie kann ich Elemente anfügen zu Beobachten

Anzahl der Antworten 3 Antworten
Wie kann ich Elemente anfügen zu Observable? Dies ist ein code: this.logEntries = this.controllerService.getLog(this.controller.remoteID, this.skip, this.max); this.logEntries.subscribe(a => { this.allLogEntries.add(this.logEntries) }); ist hier und Ihre Erklärungen: logEntries: Observable<Log>; allLogEntries: Observable<Log> = Observable.empty<Log>(); Möchte ich anfügen Elemente allLogEntries

Eigentum "existiert nicht auf Typ "Objekt". Beobachtbare abonnieren

Anzahl der Antworten 3 Antworten
Ich habe gerade angefangen mit Angular2 und ich habe ein Problem ich kann nicht wirklich verstehen. Habe ich einige mock-Daten, die als solche: export const WORKFLOW_DATA: Object = { "testDataArray" : [ { key: "1", name: "Don

ObjectUnsubscribedError, wenn Sie versuchen zu verhindern, dass zweimal abonnieren

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

Angular-async-Rohr-und Objekt-Eigenschaft

Anzahl der Antworten 3 Antworten
Ich async-Rohr ohne ngFor. Ich brauche zu überprüfen-Eigenschaft des Objekts ab, das ist async geladen mit zu beobachten. Dies ist, was ich will, aber nicht funktioniert: <ion-item *ngIf="user$.anonymouse | async"> <ion-label>Login</ion-label> </ion-item> //EDIT: ich immer diese Fehlermeldung

Beste Art und Weise zu "reduzieren" ein array innerhalb einer Beobachtbaren RxJS

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

Abrufen von Daten aus der FB-Objekt mit Angular2, angularfire2 und Typoskript

Anzahl der Antworten 1 Antworten
Im arbeitet derzeit an einem Projekt mit Winkel 2 und angularFire2. Meine Datenbank sieht wie folgt aus in der Feuerstellung: base: Daten -/ [{Name:test1}, {Name:test2}, {Name:test3}] Alle Elemente haben auch die FB-Taste. Nun im Versuch zum abrufen

Winkel-2 s-Http-Dienst nicht ausgesetzt sind, map() und andere Funktionen RxJS

Anzahl der Antworten 5 Antworten
Weiß jemand, ob es irgendwelche änderungen an den http-zwischen alpha 45 alpha 48? Ich habe auf der Suche um und ich habe nichts gefunden. Mein problem ist, dass der code unten funktioniert perfekt auf Alpha 45. Aber

Wie zu Stoppen zu beobachten.timer in Angular2

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

behaviourSubject in angular2 , wie es funktioniert und wie es zu benutzen

Anzahl der Antworten 1 Antworten
Ich versuche zu bauen, ein shared-service wie folgt import {Injectable,EventEmitter} from 'angular2/core'; import {Subject} from 'rxjs/Subject'; import {BehaviorSubject} from 'rxjs/subject/BehaviorSubject'; @Injectable() export class SearchService { public country = new Subject<SharedService>(); public space: Subject<SharedService> = new BehaviorSubject<SharedService>(null); searchTextStream$

Angular2 Beobachtbaren BehaviorSubject service nicht funktioniert

Anzahl der Antworten 2 Antworten
Ich versuche, um meine eigene beobachtbare service, aber nachdem ich die ersten Daten aus dem service, alle updates der service nicht weitergegeben an alle Abonnenten. Service sieht wie folgt aus: import { Injectable } from '@angular/core'; import

Filtern Sie eine observable, die durch Werte aus einem anderen beobachtbaren

Anzahl der Antworten 2 Antworten
Habe ich zwei observablen: Eine observable repräsentiert eine Liste von checkbox-inputs. Eine observable repräsentiert einen Strom von Ereignissen, die vom server kommt. Ich würde gerne filter die zweite beobachtbare Verwendung der Werte von der ersten. Die Werte,

Wie 'warten' für zwei observablen in RxJS

Anzahl der Antworten 5 Antworten
In meiner app habe ich so etwas wie: this._personService.getName(id) .concat(this._documentService.getDocument()) .subscribe((response) => { console.log(response) this.showForm() }); //Output: //[getnameResult] //[getDocumentResult] //I want: //[getnameResult][getDocumentResult] Dann bekomme ich zwei Ergebnisse getrennt, der erste der _personService und dann die _documentService. Wie

Was sind die Semantik von verschiedenen RxJS Themen?

Anzahl der Antworten 1 Antworten
Dokumentation zum Thema ist spärlich und es ist schwer zu entdecken, ein "entry-point" gibt. InformationsquelleAutor Ivan Kleshnin | 2016-01-18

In Angular2, wie zum abfangen von Fehler-Antwort von beobachtbaren und übergeben es an die Fehler-Kanal

Anzahl der Antworten 1 Antworten
Ich habe einen service und die Interaktion mit einem api-server. Es hat myHttpPost(Daten) Methode. Diese Methode sollte: rufen Sie Eckig ist http.post an den server if response status 200, die Antwort ist json-Inhalte, um Abonnenten wenn die

Holen Sie sich den aktuellen Wert aus Beobachtbaren ohne zu abonnieren (die wollen nur den Wert einer Zeit)

Anzahl der Antworten 3 Antworten
Der Titel sagt ja eigentlich schon alles. Wie bekomme ich den aktuellen Wert aus einem Beobachten ohne zu abonnieren? Ich möchte nur den aktuellen Wert einer Zeit-und nicht neue Werte, wie Sie kommen... Sie wollen, um Daten

RxJS: takeUntil() Winkel-Komponente ngOnDestroy()

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

angular2 Beobachtbare Eigenschaft 'debouceTime' existiert nicht auf Typ 'Beobachtbare<alle>'

Anzahl der Antworten 6 Antworten
Benutze ich "angular2 webpack" und "angular2/form,Beobachtbare" , traf aber einen Fehler ,brauche Hilfe .. Es ist ein benutzerdefiniertes Formular validator -- import {Observable} from 'rxjs/Rx'; import {REACTIVE_FORM_DIRECTIVES,FormControl, FormGroup, Validators} from '@angular/forms'; emailShouldBeUnique(control:FormControl) { return new Observable((obs:any)=> {

Winkel 2 neue Router: Wie man router-Parameter einer untergeordneten Komponente?

Anzahl der Antworten 4 Antworten
In der neuesten version von @angular/router 3.0.0-rc.1 Die Art und Weise erhalten Sie die Parameter aus einer URL/route geändert. Basierend auf diese Dokumentation, die Sie sollten in der Lage, das params-abonnieren Sie die params-aber in meinem Fall

Angular2 Http mit RXJS Beobachtbaren TypeError: this.http.bekommen(...).anzeigen(...).fangen ist nicht eine Funktion

Anzahl der Antworten 3 Antworten
Habe ich folgende Service war in Ordnung arbeiten, bis heute habe ich diese Fehler TypeError: this.http.get(...).map(...).catch is not a function. Wenn ich m Debuggen dieses Codes zum Absturz, wenn es darum geht zu fangen-Methode. import { Test

Wie kündigen/Abmelden, alle ausstehende HTTP-Anfragen Winkel-4+

Anzahl der Antworten 7 Antworten
Wie cancel/Abbrechen alle ausstehenden HTTP-Anfragen Winkel-4+. Es ist ein unsubscribe Methode zum Abbrechen der HTTP-Anfragen, aber wie brechen Sie alle ausstehenden Anfragen auf einmal. Besonders während der route ändern. Es ist eine Sache, die ich Tat ngOnDestroy()

TypeError: Sie lieferte ein ungültiges Objekt, wo ein stream zu erwarten war. Sie können Beobachten, Versprechen, Array oder Durchsuchbar

Anzahl der Antworten 7 Antworten
Ich versuche map von einem service-Aufruf aber immer einen Fehler. Sah abonnieren ist nicht definiert im Winkel 2? und er sagte, dass, um zu abonnieren, die wir brauchen, um wieder aus dem inneren der Betreiber. Ich habe

Angular2 @ Typoskript Beobachtbare Fehler

Anzahl der Antworten 1 Antworten
Ich habe ein input Feld und wenn der Benutzer eingibt einen Suchbegriff ich will warten, bis der Benutzer die Eingabe beenden, für mindestens 300 Millisekunden (debounce), bevor Sie einen _heroService http-request. Nur geänderte Suche Werte machen, durch

Einfacher Weg, um den aktuellen Wert einer BehaviorSubject mit rxjs5

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

rxjs 5 publishReplay refCount

Anzahl der Antworten 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 kann ich die Konsole.melden Sie der Wert einer beobachtbaren?

Anzahl der Antworten 1 Antworten
Ich bin mit Winkel 2 und RxJS, und ich Frage mich, wie kann ich Folgendes tun: In meine Komponente habe ich folgendermaßen definiert: count: Observable<number>; In meine Komponente Konstruktor, mache ich die folgenden: constructor( private store: Store<any>

RxJs gute tutorials

Anzahl der Antworten 2 Antworten
Ich versuche zu lernen ReactiveX. Ich habe fast einen ganzen Tag, und ich bin nicht in der Lage, um es richtig zu verstehen. Ich bemühte mich, die offizielle Dokumentation, aber ist ist sehr schwer zu verstehen. So

Wie man sich Abmelden kann von EventEmitter im Winkel 2?

Anzahl der Antworten 2 Antworten
export declare class EventEmitter<T> extends Subject<T> { /** * Creates an instance of [EventEmitter], which depending on [isAsync], * delivers events synchronously or asynchronously. */ constructor(isAsync?: boolean); emit(value: T): void; /** * @deprecated - use .emit(value) instead

wie starten und beenden Sie ein Intervall beobachtbar in RXJS?

Anzahl der Antworten 1 Antworten
Habe ich eine sehr einfache timeInterval beobachtbare und ich möchte die start/stop-übertragung, ohne dass die Abonnenten (die sollten sitzen und zu warten, unabhängig von beobachtbaren status). Ist möglich, und wenn ja, wie? var source = Rx.Observable .interval(500)

Verkettung verspricht mit RxJS

Anzahl der Antworten 3 Antworten
Ich bin neu RxJS und FRP im Allgemeinen. Ich hatte die Idee der Umwandlung eines bestehenden Versprechen Kette in meinem ExpressJS-Anwendung ein spürbarer für die Praxis. Ich bin mir bewusst, dass dies wahrscheinlich nicht das beste Beispiel

Gewusst wie: laden Sie RxJS (und zone.js / reflektieren-Metadaten) mit Winkel-2 (beta und neuer)?

Anzahl der Antworten 1 Antworten
Als der Winkel Alpha 2 54 (changelog), RxJS befindet sich nicht mehr im Winkel 2. Update: Stellt sich heraus, dass zone.js und reflect-metadata sind auch ausgeschlossen. Als Ergebnis bekomme ich jetzt den folgenden Fehler (wie man im

Wie man Letzte Wert bei der Anmeldung zu einer Beobachtbaren?

Anzahl der Antworten 2 Antworten
Habe ich zwei Angular2 Komponenten die Sie brauchen, um zu teilen, Daten über ein service: @Injectable() export class SearchService { private searchResultSource = new Subject<string>() searchResult$ = this.searchResultSource.asObservable() setSearchResults(_searchResult: string): void { this.searchResultSource.next(_searchResult) } } Angenommen ComponentA

Wie zu verwenden RxJs distinctUntilChanged?

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

Was ist der Unterschied zwischen Reactjs und Rxjs?

Anzahl der Antworten 4 Antworten
Grundsätzlich bin ich mit dem lernen anzufangen Rxjs und ich bin ein bisschen verwirrt zwischen Reagieren und Rxjs. Ich war der Meinung, Reactjs und Rxjs ist die gleiche. Fragen: Wenn Reactjs und Rxjs ist der gleiche, warum

Karte ist nicht eine Funktion (Rxjs), obwohl import

Anzahl der Antworten 5 Antworten
gab es eine Menge Fragen über "Karte ist nicht eine Funktion", aber fast jeder wusste nur nicht importiert rxjs Bibliothek. In meinem Fall, ich mache das importieren, aber der Fehler ist immer noch da. Arbeite ich mit

Separate beobachtbaren Werte von bestimmten Zeitraum in RxJS

Anzahl der Antworten 8 Antworten
Was wäre die idiomatische Weise ergeben Werte, für die erkennbar eine bestimmte Zeit? Zum Beispiel, sagen wir, ich habe eine Beobachtbare erstellt aus einem großen Array und ich möchte Ausbeute ein Wert alle 2 Sekunden. Ist eine