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.
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 } )
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
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
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
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);
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 }
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?
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
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.
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
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
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":
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 =
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
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] =
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
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
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
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
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
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
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
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; }
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$
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
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,
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
1
Antworten
Dokumentation zum Thema ist spärlich und es ist schwer zu entdecken, ein "entry-point" gibt. InformationsquelleAutor Ivan Kleshnin | 2016-01-18
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
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
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
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)=> {
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
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
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()
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
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
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;
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) =>
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>
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
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
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)
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
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
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
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 ]
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
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
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