Tag: reactive-extensions-js

Die Reactive Extensions für JavaScript ist ein Satz von Bibliotheken, die zum erstellen asynchroner, belastbar und reaktionsschnell Weg ereignisgesteuerte Programme mit beobachtbaren Sammlungen mit ECMA Script5-Array – # – extras-Stil Zusammensetzung in JavaScript.

Synchronität in RxJS

Anzahl der Antworten 1 Antworten
Ich würde erwarten, dass der folgende code asynchron ausführen: var range = Rx.Observable.range(0, 3000000); range.subscribe( function(x) {}, function(err) {}, function() { console.log('Completed'); }); console.log('Hello World'); Aber das ist nicht der Fall. Es dauert eine Weile, um durch

RxJs: poll, bis Intervall gemacht oder korrekten Daten empfangen

Anzahl der Antworten 3 Antworten
Wie führe ich das folgende Szenario im browser mit RxJs: übermitteln von Daten in der Warteschlange für die Verarbeitung wieder die job-id poll anderen Endpunkt alle 1s, bis das Ergebnis verfügbar ist oder 60 Sekunden vergangen sind(dann

Sammeln RxJS Observable-Array

Anzahl der Antworten 1 Antworten
Ich verwenden möchte, RxJS "Brücke" async Welt der Veranstaltungen mit sync-Welt. Speziell möchte ich erstellen Sie eine Funktion, die liefert ein array der gesammelten Ereignisse während bestimmter Zeit-Intervall. Kann ich Beobachten, das tut was ich will var

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,

Kann ich beobachten, Ergänzungen, ein array mit rx.js?

Anzahl der Antworten 4 Antworten
fromArray Rx-wiki auf github coffee> rext = require 'rx' coffee> arr = [1..5] [ 1, 2, 3, 4, 5 ] coffee> obs = rext.Observable.fromArray(arr) { _subscribe: [Function] } coffee> obs.subscribe( (x) -> console.log("added value: " + x))

Angular2 RxJS erhält "Observable_1.Observable.fromEvent ist kein Fehler der Funktion"

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

Rxjs Flatmap fehlt

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

Veröffentlichen Sie den letzten Wert einer Observablen

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