Tag: rxjs

Ich versuche zu lernen RxJS mit websockets und Winkel 4, und fand ein gutes Beispiel hier. Ich hoffe jemand kann helfen, zu erklären, die als Beispiel ein paar Dinge, die verwirrend sind. Haben Sie geschaffen, 2 Winkel-services,

Ich habe ein array welches ich gerne zu filtern.. klingt einfach, ich weiß. Aber wenn ich das mache, bekomme ich noch das gesamte Array... constructor(http:Http) { this._val = Math.random(); let s = http.get('https://secure.digitalsignage.com/Digg'); s.map(s => { let

Ich habe ein Problem mit einem Abo-zu einem beobachtbaren, nicht auslösen. Habe ich ein layout mit den seitlichen nav-layout-Direktive so Aussehen: <md-sidenav-layout class="nav-bar"> <md-sidenav #start> <nav> <a [routerLink]="['/home']">Home</a> </nav> <button md-button (click)="start.close()">Close</button> </md-sidenav> <router-outlet></router-outlet> </md-sidenav-layout> Was ich

Ich bin nur zu lernen, angular2. Die bei der Anmeldung etwas am Eingang ändert, ich bin immer der Fehler. app.ts: export class AppComponent { form: ControlGroup; constructor(fb: FormBuilder) { this.form = fb.group({ search: }); var search

In einer eckigen Anwendung haben wir ngOnDestroy() lifecycle-Haken für eine Komponente /Richtlinie, und wir verwenden diesen Haken zum abbestellen der observablen. Möchte ich klar /destory beobachten, die erstellt werden, in einem @injectable() service. Ich sah einige Beiträge,

Möchte ich RxJS in meinem socket.on('sense',function(data){});. Ich komme nicht weiter und verwirrt mit nur sehr wenige Unterlagen zur Verfügung und mein Mangel an Verständnis RxJS. Hier ist mein problem. Ich habe eine distSensor.js hat eine Funktion pingEnd()

Für eine Web-Anwendung geschrieben, mit Angular2 in Typoskript, ich muss arbeiten mit RxJs Observables. Da ich nie verwendet rxjs vor und ich bin neu in reactiveprogramming im Allgemeinen, ich habe manchmal Schwierigkeiten den richtigen Weg zu finden,

Habe ich gelernt Winkel-4 und alles lief glatt, bis ich versucht zu implementieren, fangen, handling im service. Ich versuche, rxjs fangen und werfen, aber ich habe eine Undefinierte Funktion error in meiner Konsole. import { Injectable }

Ist es weiterhin möglich forkjoin http.get-Anforderungen, auch wenn eine der Anforderungen scheitert. Ich bin auf der Suche auf eine ähnliche Funktion von $q.allSettled in angular2. Siehe Beispiel : http://jsfiddle.net/Zenuka/pHEf9/ angular.module('qAllSettled', ).config(function($provide) { $provide.decorator('$q', function($delegate) { var $q

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) =>

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

Was ist der richtige Weg, um json-Daten von einem http-get in den Winkel-2. Ich arbeite an Tests, einige der lokalen Daten mit einer verspottet Endpunkt, und ich kann sehen, das Ergebnis in die http.get() aber kann ich

Wenn Sie versuchen, um den Typ eines Attributs bekomme ich die Fehlermeldung Cannot find name 'Subscription'. Aus dem Paket muss ich importieren? import { Component, OnDestroy, OnInit } from '@angular/core'; import { ActivatedRoute, Router } from '@angular/router';

Ich bin mir nicht klar über den Unterschied zwischen einem Thema und einem BehaviorSubject. Ist es nur, dass ein BehaviorSubject hat die getValue-Funktion? InformationsquelleAutor der Frage Mike | 2017-04-11

Brauche ich zum erstellen eines Abonnements für einen beobachtbaren, wird sofort entsorgt, wenn es zuerst genannt. Gibt es so etwas? Sowas zu beobachten.subscribeOnce(func) Meine, ich bin ein Abonnement erstellen, die in einer express route-handler und das Abonnement

In Den Winkel-1.x ich würde manchmal müssen mehrere http Anfragen und tun Sie etwas mit all den Antworten. Ich würde werfen alle die Verheißungen in ein array und call Promise.all(promises).then(function (results) {...}). Winkel 2 best practices scheinen,

Ich soll einen Fehler auslösen, aus meiner beobachtbar ist Karte Betreiber basierend auf einer Bedingung. Zum Beispiel, wenn die richtige API-Daten werden nicht empfangen. Bitte sehen Sie den folgenden code: private userAuthenticate( email: string, password: string )

Ich bin gerade dabei, mir beibringen, Angular2 und Typoskript nach glücklich die Arbeit mit AngularJS 1.* für die letzten 4 Jahre! Ich muss zugeben, ich bin hassen, aber ich bin sicher, dass mein eureka moment ist gleich

Wie wirkt sich eine Kündigung des Abos in Angular2? RxJS scheint eine dispose-Methode, aber ich kann nicht herausfinden, wie Zugriff. Also ich habe code, der Zugang zu einem EventEmitter und abonniert Sie, wie diese: var mySubscription =

//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

Ich würde gerne etwas wie: this._myService.doSomething().subscribe(result => { doSomething() }); .then( () => dosthelse() ) .then( () => dosanotherthing() ) Also ich würde gerne die Kette .dann wie im Versprechen. Wie würde ich das tun in Rxjs?

Begann ich mit Angular2 Observableaber ich kann nicht finden, etwas ähnliches zu .then dass ich mit Promises. Dies ist, was ich erreichen will. code aus dem header.Komponente.ts public login() { this._user = AuthService.getInstance().login(this._loginInfo); } code vom auth.service.ts

Ich bin mit AngularJS 2 Beta 0 und ich bin versucht, zu erstellen eine RxJS Beobachten von einem Ereignis auf ein Fenster-Objekt. Ich glaube, ich weiß die Formel für die Erfassung der Veranstaltung, als eine Beobachtbare in

Habe ich eine Eckige 2-Anwendung. Ein Dienst fordert Daten von einer api, dass die Ergebnisse wie die folgenden: { "data":[ {"id":1,"timestamp":"2016-04-17T19:52:53.4510935+01:00","sourceDatabaseServer":"127.0.0.1","sourceDatabaseName":"Database1","targetDatabaseServer":"192.168.99.101","targetDatabaseName":"Database2"}, {"id":2,"timestamp":"2016-04-17T19:52:53.4510935+01:00","sourceDatabaseServer":"127.0.0.2","sourceDatabaseName":"Database3","targetDatabaseServer":"192.168.99.102","targetDatabaseName":"Database4"}, {"id":3,"timestamp":"2016-04-17T19:52:53.4510935+01:00","sourceDatabaseServer":"127.0.0.3","sourceDatabaseName":"Database5","targetDatabaseServer":"192.168.99.103","targetDatabaseName":"Database6"} ] } Meine Winkel 2 service sieht wie folgt aus (ich habe geschnitten, die

In Winkel-docs gibt es ein Thema, über das Zuhören für Kinder-events von den Eltern. Das ist in Ordnung. Aber meine Absicht ist es etwas Umgekehrt!. In meiner app gibt es einen " admin.die Komponente', die hält die