Tag: reactive-programming

Reaktive Programmierung ist ein Paradigma orientiert sich an Daten-Ströme und die Ausbreitung der Veränderung.

Wie behandeln Sie "Fertig" return-Taste drücken Veranstaltung in rxSwift?

Anzahl der Antworten 3 Antworten
Beim erkunden RxSwift Fand ich nur textField.rx_text.asObservable() Eigenschaft, das feuert-Ereignis jeder Schaltfläche Tastatur ist der hit. Aber wie gehen wir mit "Suche" oder "fertig" - button drücken-events? Ich würde gerne Feuer suchen nur nach diesen Aktionen, nicht

Vergleich von Java-reaktiven frameworks

Anzahl der Antworten 1 Antworten
Sehe ich sehr viele frameworks/Bibliotheken, die behaupten, Sie kann dabei helfen, reaktive Anwendungen in Java, wie zum Beispiel: Akka, Vert.x, RxJava, Reaktor, QBit, etc. Scheinen Sie haben unterschiedliche Ansätze, Funktionen, Vorteile, Nachteile, etc. Ich konnte nicht finden,

Angular 2.0 - konvertieren von Versprechen, die die Verkettung mit physikalischen Grössen

Anzahl der Antworten 2 Antworten
Bin ich mit der Konvertierung eines NG-1.X service-NG 2.0. Mein NG 1.X service hat Versprechen chaining (vereinfacht): dataService.search = function(searchExp) { return this.getAccessToken() .then(function(accesstoken) { var url = $interpolate('https://my-api-url?q={{search}}&{{accesstoken}}')({search: searchExp, accesstoken: accesstoken}); return $http({ url: url, method:

Wert von einem select HTML element reaktiv mit Meteor

Anzahl der Antworten 2 Antworten
Ich will, um den Wert eines HTML - <select> element reaktiv, ohne änderung der verschiedenen Optionen für das element ein. Ich habe eine Lösung gefunden, aber es in nicht elegant. Erstellen Sie zum testen ein Barebone-Meteor-app mit

RxJava Kombinieren Sequenz Von Anfragen

Anzahl der Antworten 5 Antworten
Das Problem Habe ich zwei Apis. Api-1 gibt mir eine Liste der Elemente und Api-2-gibt mir mehr detaillierte Informationen für die einzelnen Elemente habe ich aus Api-1. Die Art, wie ich es gelöst bisher Ergebnisse in schlechte

Empfohlene Lektüre/tutorials, um zu verstehen, reactive-banana FRP-Bibliothek

Anzahl der Antworten 6 Antworten
Geschlossen. Diese Frage ist die Meinung basiert. Es ist derzeit nicht akzeptieren Antworten. mehr. verbessern Wollen dieser Frage? Update die Frage kann also beantwortet werden mit Fakten und Zitate von Bearbeiten diesem post. Geschlossen 4 Jahre vor.

Vorteile .NETTO-Rx über die klassische Ereignisse?

Anzahl der Antworten 4 Antworten
.NET 4.0 beta 2 hat eingeführt die IObservable und IObserver Schnittstellen. Was sind die Vorteile im Vergleich zu klassischen .NET-events? Dies nicht dasselbe problem zu lösen? Von einem cross-Technologie-Perspektive, Rx kann (und hat) umgesetzt, um die gleichen

Mit System.Reaktive in .NET 3.5 (in ein Versand-Produkt)

Anzahl der Antworten 2 Antworten
Geschlossen. Diese Frage ist off-topic. Es ist derzeit nicht akzeptieren Antworten. mehr. verbessern Wollen dieser Frage? "Update" die Frage so ist es on-topic für Stack-Überlauf. Diese Frage nicht mehr relevant ist nun, dass microsoft veröffentlichte eine richtige

Wie behandeln Sie Ausnahmen, die ausgelöst durch Beobachter onNext in RxJava?

Anzahl der Antworten 1 Antworten
Betrachten Sie das folgende Beispiel: Observable.range(1, 10).subscribe(i -> { System.out.println(i); if (i == 5) { throw new RuntimeException("oops!"); } }, Throwable::printStackTrace); Diese Ausgaben zahlen von 1 bis 5 und dann druckt die Ausnahme. Was ich erreichen will

Wie leicht zu konvertieren oder zuweisen eine Beobachtbare Verhaltensweise Unterliegen, so dass andere Komponenten können teilen Sie es

Anzahl der Antworten 2 Antworten
Ich bin neu auf Beobachtbaren Stil Programmierung. Ich habe eine Frage: ich möchte über Benutzer-info in der app zwischen den Komponenten - - - und ich benutze BehaviorSubject teilen dieser info. Dies ist inspiriert durch den Austausch

Wie handle Fehler beim ausführen von Flux.anzeigen()

Anzahl der Antworten 4 Antworten
Im Versuch, herauszufinden, wie behandeln von Fehlern beim zuordnen von Elementen innerhalb eines Flux. Beispielsweise Im analysieren einer CSV-string in einen von meinem Geschäft POJOs: myflux.map(stock -> converter.convertHistoricalCSVToStockQuotation(stock)); Einige dieser Zeilen welche Fehler enthalten kann, so was

Erstellen Beobachten, ohne die Verwendung zu Beobachten.erstellen

Anzahl der Antworten 2 Antworten
Ich bin mit RxJava in meine Android-app und ich möchte das laden der Daten aus der Datenbank. In dieser Weise, erstelle ich eine neue Observable mit Observable.create() gibt eine Liste von EventLog public Observable<List<EventLog>> loadEventLogs() { return

Feder 5 Web-Reaktiven - Wie können wir WebClient abrufen-Stream von Daten in einem Fluss?

Anzahl der Antworten 2 Antworten
Den aktuellen Meilenstein (M4) - Dokumentation zeigt und Beispiel darüber, wie das abrufen einer Mono mit WebClient: WebClient webClient = WebClient.create(new ReactorClientHttpConnector()); ClientRequest<Void> request = ClientRequest.GET("http://example.com/accounts/{id}", 1L) .accept(MediaType.APPLICATION_JSON).build(); Mono<Account> account = this.webClient .exchange(request) .then(response -> response.body(toMono(Account.class))); Wie

Ist das Reaktive Framework (RX) für den Einsatz in der Mono-noch?

Anzahl der Antworten 5 Antworten
Gesucht, aber das einzige, was ich fand, war http://evain.net/blog/articles/2009/07/30/rebasing-system-reactive-to-the-net-clr, die ich habe zu arbeiten, aber es fühlt sich an wie es sollte ein einfacher Weg, besonders da rx war die erste Veröffentlichung zurück, in der Mitte 09.

Sequenz von Aktionen mit RxSwift

Anzahl der Antworten 2 Antworten
Ich bin mit RxSwift einfach meinen code. Für mein Aktuelles Projekt würde ich gerne übernehmen RxSwift Prinzipien zu einem Chaos der Fertigstellung blocks von der LayerKit: layerClient.connectWithCompletion { (success, error) -> () in if (!success) { //Error

Was ist die "callback-Hölle" und wie und warum tut RX es lösen?

Anzahl der Antworten 6 Antworten
Kann jemand eine klare definition zusammen mit einem einfachen Beispiel erklärt, was ein "callback-Hölle" für jemanden, der nicht weiß, JavaScript und node.js ? Wann (in welcher Art von Einstellungen) ist die "callback-Hölle-problem" auftreten? Warum tritt es auf?

RxJs: Wie eine Schleife basierend auf dem Status des beobachtbaren?

Anzahl der Antworten 2 Antworten
Ich versuche RxJs, um eine Schleife über einen Beobachtbaren in meinem stream, bis es in einem bestimmten Zustand, dann den stream weiter. Speziell ich die Umwandlung einer synchronen do/while-Schleife RxJs, aber ich nehme an, die gleiche Antwort

Erhalten Sie die neuesten Wert einer Beobachtbaren und emittieren es immeditely

Anzahl der Antworten 3 Antworten
Ich versuche, den aktuellen Wert eines bestimmten Observable und bekommen es zu emittieren sofort, sobald es aufgerufen wird. Angesichts des folgenden code als Beispiel: return Observable.just(myObservable.last()) .flatMap(myObservable1 -> { return myObservable1; }) .map(o -> o.x) //Here I

Warten für die parallele RX-Abonnenten zu vervollständigen

Anzahl der Antworten 3 Antworten
Ich bin auf der Suche nach der besten Methode zu warten, bis asynchrone Aufgaben zu erledigen, die im rx-java. Als eine gemeinsame Beispiel, sagen, dass es eine Funktion bekommt eine Liste von id 's aus einem lokalen

Verhalten von onNext und onComplete

Anzahl der Antworten 3 Antworten
Ich habe eine Observable, die etwas tut, ohne die Notwendigkeit, geben einen Wert ein. Auch ich habe eine Liste von Objekten, ich will das Beobachten, mit zu arbeiten. Also für alle Elemente in dieser Liste: doSomething() Observable.from(uris)

RxJS beobachtbar ist nicht abgeschlossen, wenn ein Fehler Auftritt

Anzahl der Antworten 3 Antworten
Wenn ich eine beobachtbare, von Grund auf, und haben die Beobachter-Fehler, dann komplett fertig Teil der Abonnement-nie aufgerufen. var observer = Rx.Observable.create(function(observer){ observer.onError(new Error('no!')); observer.onCompleted(); }) observer.subscribe( function(x) { console.log('succeeded with ' + x ) }, function(x)

Wie zu verwenden zu Beobachten.fromCallable() eine checked Exception?

Anzahl der Antworten 2 Antworten
Observable.fromCallable() ist ideal für die Umwandlung einer Funktion in eine Beobachtbare. Aber wie gehst du mit Ausnahmen geprüft werden könnten, ausgelöst durch die Funktion? Meisten der Beispiele, die ich gesehen habe, Lambda-Ausdrücke und "einfach funktionieren". Aber wie

Reaktive Programmierung Vorteile/Nachteile

Anzahl der Antworten 6 Antworten
Ich studiere weiter und versuchen Reaktiven Stil der Codierung mit Reaktor und RxJava. Ich verstehe, dass reaktive Codierung ermöglicht eine bessere Auslastung der CPU im Vergleich zum single-threaded-Ausführung. Gibt es irgendwelche konkreten Vergleich zwischen reaktiver Programmierung vs.

Wie ist reaktive Programmierung anders als ereignisgesteuerte Programmierung?

Anzahl der Antworten 4 Antworten
Ich Lerne reaktive Programmierung und funktionale reaktive Programmierung in JavaScript. Ich bin sehr verwirrt. Wikipedia sagt, es gibt verschiedene Möglichkeiten, zu schreiben reaktive code wie Imperativ, OORP und funktional. Ich möchte wissen, ob event-driven ist nur eine

Wie stellen Sie den countdown-timer mit RxJS Observablen?

Anzahl der Antworten 2 Antworten
Ich bin kämpfen, um erstellen Sie einen countdown-timer mit Observablen, die Beispiele auf http://reactivex.io/documentation/operators/timer.html nicht zu funktionieren scheint. In diesem konkreten Beispiel wird der Fehler bezogen auf timerInterval nicht eine Funktion des Beobachtbaren kehrte aus-timer. Habe ich

werfen Fehler in rxjs Beobachten

Anzahl der Antworten 3 Antworten
Ich versuche zu werfen, einen Fehler innerhalb einer rxjs Beobachtbaren new Observable(subscriber => { Observable.throw("error1"); return Observable.throw("error2"); }) .subscribe( () => {}, err => console.error(err) ); Fehler 1 ist nicht gefangen. error2 gibt einen Kompilierungsfehler: Argument of

Problem mit rx.Tippen Sie für UIButton in UICollectionViewCell - RxSwift 3

Anzahl der Antworten 2 Antworten
Ich abonniere 2 mal für 1 UIButton : Erste Abonnement für die Aktualisierung von UI auf jeden Klick Zweite Abonnement für die Aktualisierung der Werte auf Web-Service-alle 1 Sekunde nach Klicks angesammelt. Code: class ProductionSize { var

Howto Rückruf async-Funktion von rx zu abonnieren?

Anzahl der Antworten 3 Antworten
Würde ich mag, um den Anruf wieder eine async-Funktion innerhalb eines Rx-Abonnement. E. g. so: public class Consumer { private readonly Service _service = new Service(); public ReplaySubject<string> Results = new ReplaySubject<string>(); public void Trigger() { Observable.Timer(TimeSpan.FromMilliseconds(100)).Subscribe(async

Verkettung Observablen in RxJS

Anzahl der Antworten 1 Antworten
Ich Lerne RxJS und Eckig 2. Sagen wir, ich habe ein Versprechen Kette mit mehreren asynchronen Funktionsaufrufen, mit denen abhängen, die auf dem vorhergehenden Ergebnis, das wie folgt aussieht: var promiseChain = new Promise((resolve, reject) => {

Holen Sie string-Wert aus Beobachtbaren<string> in Maschinenschrift und Eckig

Anzahl der Antworten 1 Antworten
Möchte ich, um string-Wert aus Beobachtbaren und Wert aus der Funktion an den Aufrufer der Funktion. ZB: Ich habe die array-Schlüssel und würde gerne Hole den Wert (string), alle Schlüssel nacheinander und Anzeige von html-Komponenten die Menüleiste.

Ruft setState render ist nicht vermeidbar

Anzahl der Antworten 1 Antworten
Reagieren Dokument besagt, dass die render Funktion sollte Reine was bedeutet, es sollte nicht mit this.setState.Ich glaube jedoch, dass, wenn der Staat angewiesen auf "remote", d.h. Ergebnis von ajax-call.Die einzige Lösung ist setState() innerhalb einer render Funktion

How to get String von Mono<String> in reaktiven java

Anzahl der Antworten 5 Antworten
Habe ich eine Methode, die akzeptiert Mono-als param. Alles was ich will ist, um die tatsächliche Zeichenfolge aus. Gegoogelt aber finde nicht die Antwort, außer den Aufruf blockieren() über Mono-Objekt, aber es wird ein blockierender Aufruf so

Wie behandeln onError-innen RxJava. Ich bin immer "OnErrorNotImplementedException"

Anzahl der Antworten 3 Antworten
In meiner app verwende ich ReactiveLocationProvider Bibliothek (link). Ich subscribe for updates " in der onCreate-Methode. Es funktioniert, wenn das Gerät online ist, aber wenn ich schalte mein WLAN aus, und warten Sie für die nächste Standortaktualisierung

Sortieren-array in RxJS

Anzahl der Antworten 2 Antworten
RxJava hat eine Methode toSortedList(Comparator comparator) wandelt einen Fluss von Objekten in eine Liste von Objekten sortiert, die von einem Komparator. Wie kann ich erreichen das gleiche in JavaScript mit RxJS und erhalten eine Beobachtbare mit einem

Eine gültige Reagieren element (oder null) zurückgegeben werden muss. Sie müssen möglicherweise undefined zurückgegeben wird, ein array oder eine andere ungültige Objekt

Anzahl der Antworten 3 Antworten
Ich bin gerade neu in ReactJS und ich haben ein problem. Ich kann es nicht lösen. Es scheint, alles ist in Ordnung, aber immer noch die Konsole gibt mir: Einen gültigen Reagieren element (oder null) zurückgegeben werden

Wie zu blockieren thread zu warten, für die Reaktion in vert.x?

Anzahl der Antworten 3 Antworten
Habe ich eine situation, wo ich rufen Sie eine externe API zu und nutzen Sie dessen Reaktion zu ernähren, auf Anfrage API-B und nennen es und hinterher wieder die Antwort zum Aufrufer der API-A. so Etwas wie

Gewusst wie: überschreiben Sie die Breite des TextField-Komponente mit reagieren Material-UI?

Anzahl der Antworten 3 Antworten
Ich bin versucht, um die Breite der Komponente : https://github.com/callemall/material-ui/blob/master/src/TextField/TextField.jsx Hier ist der render-Methode : render() { return ( <div> <div> <form onSubmit={this.handleSubmit}> <TextField hintText="Email" ref="email" /><br/> <TextField hintText="Password" type="password" ref="password" /><br/> <button className="btn btn-success" onClick={this.loginCommand}><i className="fa

Meteor - Wie kann ich die übergabe von Daten zwischen Helfer und Veranstaltungen für eine Vorlage?

Anzahl der Antworten 2 Antworten
Ich bin ein bisschen neu zu Meteor und etwas, das ich Probleme habe mit reaktiver Daten-vor allem in Instanzen, wo ich brauche zum ändern der angezeigten Daten basierend auf einem Maus-oder Tastatur-Ereignis. Diese Art von Zeug, die

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

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;

Reagieren JS: Erklärung des dies.Requisiten.Elemente.map-Funktion

Anzahl der Antworten 4 Antworten
Ich bin mit Reagieren JS zum Rendern der HTML-Inhalt. Das Problem ist, ich bin nicht in der Lage zu verstehen, insbesondere Abschnitt von code, was es tut. Wenn Sie sehen können, ein basic-Beispiel einer Todo-Liste aus dem

RxSwift Wie zu verwenden combineLatest?

Anzahl der Antworten 1 Antworten
Habe ich definiert: let currentHours:Variable<Float> = Variable(0.0) let currentRate:Variable<Float> = Variable(0.0) und ich möchte, um eine Beobachtbare mit combineLatest, um die Summe dieser beiden Wert: Observable.combineLatest(currentHours, currentRate, { (h, r) -> Float in return Float(h+r) }) und

Betreff vs BehaviorSubject vs ReplaySubject in Angular

Anzahl der Antworten 1 Antworten
Ich habe auf der Suche zu verstehen, die 3: ThemaVerhalten unterliegt und Replay Thema. Ich würde Sie gerne benutzen und wissen, Wann und warum, was sind die Vorteile der Verwendung von Ihnen und zwar habe ich mir

RxJava Beobachten beim Aufruf / Abonnieren des Threads

Anzahl der Antworten 2 Antworten
Ich habe einige Schwierigkeiten Verständnis, wie subscribeOn/observeOn arbeitet in RxJava. Ich habe einfach app mit beobachtbaren, strahlt Sonnensystem Planeten-Namen, erfolgt eine Zuordnung und Filterung und druckt die Ergebnisse. So wie ich das verstehe, Planung der Arbeit, um

Split Rx Observable in mehrere Streams und einzeln verarbeiten

Anzahl der Antworten 2 Antworten
Hier ist ein Bild von dem, was ich bin versucht zu erreichen. --a-b-c-a--bbb--ein aufgeteilt in --a------------ --> ein Strom ----b------bbb--- --> b-stream ------ c---------- --> c-stream Dann in der Lage sein, a.subscribe() b.subscribe() c.subscribe() So weit, alles,

Wann kann ich ein Abonnement abbestellen?

Anzahl der Antworten 3 Antworten
Ich habe eine Frage bezüglich, wie man sich Abmelden eine beobachtbare. Ich habe zwei codes und ich bin mir nicht wirklich sicher, welches besser ist. Beispiel 1 -> Abmelden Abonnenten, sobald der stream beendet ist: Subscriber<String> subscriber

Kombiniere eine Liste von Observablen und warte, bis alles abgeschlossen ist

Anzahl der Antworten 6 Antworten
TL;DR Wie konvertiert Task.whenAll(List<Task>) in RxJava? Meinen vorhandenen code verwendet Schrauben zu bauen, um eine Liste von asynchronen Aufgaben und wartet, bis alle diese Aufgaben zu beenden, bevor er andere Schritte. Im wesentlichen, es baut sich eine

In RxJava, wie man eine Variable bei der Verkettung von Observablen weiterleitet?

Anzahl der Antworten 6 Antworten
Ich bin Verkettung asynchronen Operationen, die mit RxJava, und ich möchte einige Variablen downstream: Observable .from(modifications) .flatmap( (data1) -> { return op1(data1); }) ... .flatmap( (data2) -> { //How to access data1 here ? return op2(data2); })

Was ist "Callback-Hölle" und wie und warum löst RX es?

Anzahl der Antworten 5 Antworten
Kann jemand eine klare definition zusammen mit einem einfachen Beispiel erklärt, was ein "callback-Hölle" für jemanden, der nicht weiß, JavaScript und node.js ? Wann (in welcher Art von Einstellungen) ist die "callback-Hölle-problem" auftreten? Warum tritt es auf?

RxJava: Wie erstellt man mehrere Observables mit Abhängigkeiten und sammelt alle Ergebnisse am Ende?

Anzahl der Antworten 3 Antworten
Ich Lerne RxJava und mein erste experiment, zu versuchen, zu schreiben, die code in der ersten run() Methode in dieser code (zitiert auf Netflix-blog als problem RxJava kann helfen, lösen) zu verbessern, seine Asynchronität mit RxJava, d.h.