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.
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
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
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
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,
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))
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
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
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,