Suchergebnisse für Anfrage "reactive-programming"
Rxjs - API-Ausgabe konsumieren und erneut abfragen, wenn der Cache leer ist
Ich versuche eine Version von @ zu implementierdieses Intro zu RxJS [https://xgrommx.github.io/rx-book/content/guidelines/introduction/index.html] ( geige hier [http://jsfiddle.net/staltz/8jFJH/48/]) Anstatt ein zufälliges Objekt aus einem ...
Mehrere Timer mit reaktiven Erweiterungen erstellen
Ich habe eine sehr einfache Klasse, die ich verwende, um ein Verzeichnis nach neuen Dateien abzufragen. Es gibt den Standort, eine Zeit, um mit der Überwachu...
Stream Reasoning / Reaktive Programmierung in Prolog?
Ich habe mich gefragt, ob Sie eine Möglichkeit kennen, Prolog für die Stream-Verarbeitung zu verwenden, dh eine Art reaktive Programmierung, oder zumindest e...
RxJava: Wie erstelle ich mehrere Observables mit Abhängigkeiten und sammle am Ende alle Ergebnisse?
Ich lerne RxJava und versuche als erstes Experiment, den Code im ersten zu schreibenrun() Methode indieser Code [https://gist.github.com/benjchristensen/4671081](Zitiert amNetflixs ...
Warum sollten wir Verhalten in FRP verwenden
Ich lerne reaktive Banane. Um die Bibliothek zu verstehen, habe ich mich entschieden, eine Dummy-Anwendung zu implementieren, die einen Zähler erhöht, wenn jemand einen Knopf drückt. Die UI-Bibliothek, die ich verwende, ist Gtk, aber das ist ...
EventBus / PubSub vs (reaktive Erweiterungen) RX hinsichtlich der Code-Klarheit in einer Anwendung mit einem Thread
Zur Zeit benutze ich einen EventBus /PubSub [http://en.wikipedia.org/wiki/Publish%E2%80%93subscribe_pattern]Architektur / Muster mit Scala (und JavaFX) zur Implementierung einer einfachen Notiz-Organisations-App (ähnlich einem Evernote-Client mit ...
Wie erstelle ich eine Observable von OnClick Event Android?
Ich bin neu in der reaktiven Programmierung. Ich habe also ein Problem beim Erstellen eines Streams aus einem Event, wie onClick, uponuch ... Kann mir jemand helfen, dieses Problem zu lösen. Vielen Dank.
Idiomatische Methode zur Wiederherstellung von Stream onError
Disclaimer: Es ist die Fortsetzung des vorherigenSafe Update für 2 abhängige Streams [https://stackoverflow.com/q/27596693/251311] question Was ist deridiomatisc Möglichkeit, Fehler in RxJS (oder einer anderen RX-Implementierung) zu behandeln, ...
Bietet Scala asynchrone, nicht blockierende E / A-Vorgänge bei der Arbeit mit Dateien?
Ich verwende Scala 2.10 und frage mich, ob es ein Paket gibt, das bei der Arbeit mit Dateien asynchrone E / A hat. Ich habe nach diesem Thema gesucht, aber meistens die folgenden Beispiele gefunden: val file = new File(canonicalFilename) val bw ...
Implementieren eines Drehkreuz-ähnlichen Operators mit RxJava
Ich brauche Hilfe bei der Implementierung eines Drehkreuz-ähnlichen Operators in RxJava (RxScala). Ich habe eine ganze Weile darüber nachgedacht, aber ich scheine festzustecken. Der Typ der Funktion sollte der folgende sein: def ...