Suchergebnisse für Anfrage "reactive-programming"
In Slick / Scala streamen
Ich schaue mir Scala / Slick-Streaming an und versuche zu verstehen, wie es funktioniert. Hier ist mein Testcode val bigdata = TableQuery[BigData] val x = db.stream(bigdata.result.transactionally.withStatementParameters(fetchSize ...
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 ...
Kann ich den alten Wert eines reaktiven Objekts speichern, wenn es sich ändert?
Hinweis Nachdem ich die Antwort gefunden hatte, formulierte ich die Frage neu, um sie klarer zu machen. Manchmal in einemshiny App. Ich möchte einen Wert verwenden, den der Benutzer für ein Widget ausgewählt hat, sowie den vorherigen Wert, der ...
Marmordiagramme [geschlossen]
Die Marmordiagramme stammen häufig vom Rx-Team und erläutern, wie bestimmte Operatoren in Rx funktionieren. Gibt es ein Tool zum Erstellen der Marmordiagramme?
C # .NET Rx- Wo ist System.Reactive?
Ich habe einen intensiven Java-Hintergrund. Verzeih mir, wenn ich etwas Offensichtliches in C # übersehen habe, aber meine Recherchen bringen mich nicht weiter. Ich versuche, die reaktive Rx .NET-Bibliothek zu verwenden. Der Compiler beschwert ...
RxJava- Ist cache () dasselbe wie replay ()?
Ich habe mich gefragt, ob es ein @ gcache() -Operator, der x Anzahl von Emissionen zwischenspeichern, sie aber auch nach einem bestimmten Zeitintervall (z. B. 1 Minute) verfallen lassen könnte. Ich suchte nach etwas wie ...
Prüfung in reaktiven Bananen
Gibt es eine Möglichkeit, in reaktiven Bananen erstellte Unit-Test-Netzwerke zu erstellen? Angenommen, ich habe ein Netzwerk mit einigen Eingabeereignissen aufgebaut. Ist es möglich, zu überprüfen, ob Ereignisse nach einer bestimmten Anzahl von ...
Wie implementiere ich observLatestOn in RxJava (RxScala)?
Ich versuche das @ zu implementier ObserveLatestOn [https://social.msdn.microsoft.com/Forums/en-US/bbcc1af9-64b4-456b-9038-a540cb5f5de5/how-do-i-ignore-allexceptthelatest-value-when-my-subscribe-method-is-running?forum=rx>] Operator in RxJava ...
Verwalten Sie identische Anfragen mit RxJava
Angenommen, ich habe einen Fetcher, der ein Bild von einem bestimmten Link in einem separaten Thread abruft. Das Bild wird dann im Speicher zwischengespeichert. Sobald das Bild bereits zwischengespeichert wurde, ruft der Fetcher den Link nicht ...