Suchergebnisse für Anfrage "reactive-programming"
Wie man die Parallelität in Rx.NET richtig einschränkt
Bitte beachten Sie den folgenden Codeausschnitt: var result = await GetSource(1000).SelectMany(s => getResultAsync(s).ToObservable()).ToList(); Das Problem mit diesem Code ist, dassgetResultAsync wird gleichzeitig ohne Einschränkungen ...
RxJava Beobachten beim Aufrufen / Abonnieren des Threads
Ich habe einige Probleme zu verstehen, wie subscribeOn / observOn in RxJava funktioniert. Ich habe eine einfache App mit Observable erstellt, die Planetennamen des Sonnensystems ausgibt, Kartierungen und Filterungen vornimmt und Ergebnisse ...
Fighting mit FRP
Ich habe über FRP gelesen und war sehr aufgeregt. Es sieht gut aus, so dass Sie mehr Code auf hoher Ebene schreiben können, und alles ist komponierbarer und so weiter. Dann habe ich versucht, mein eigenes kleines Spiel mit ein paar hundert ...
Ist Slick 3.0 auf Datenbanktreiberebene reaktiv / asynchron? Für welche Datenbanken?
Slick hat sich in der Vergangenheit auf JDBC-Treiber verlassen, die intern das Warten auf Socket-E / A als Antwort auf Abfragen blockieren. Jeder ausstehende Datenbankaufruf erfordert einen Thread zum Blockieren eines Sockets. Daher ist es nicht ...
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 ...
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 ...
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 ...
Kette zwei nachrüstbare Observables mit RxJava
Ich möchte 2 Netzwerkanrufe nacheinander ausführen. Beide Netzwerkanrufe geben Observable zurück. Zweiter Aufruf verwendet Daten vom erfolgreichen Ergebnis des ersten Aufrufs, Methode im erfolgreichen Ergebnis des zweiten Aufrufs verwendet Daten ...
Wie Aufgabe mit Retrofit und rxjava abbrechen
Ich habe Ruhe api. @Get("/serveraction") public Observable<String> myRequest(@Query("Data") String data);Ich weiß, dass okhttp eine Abbruchfunktion hat (nach Anfrageobjekt, nach Tag), aber ich weiß nicht, wie ich es mit Retrofit und rxjava ...
Wie mache ich einen rekursiven, beobachtbaren Aufruf in RxJava?
Ich bin ziemlich neu bei RxJava [https://github.com/ReactiveX/RxJava] (und das reaktive Paradigma im Allgemeinen), bitte nehmen Sie Kontakt mit mir auf. ngenommen, ich habe diesesNews und dieses verschachtelteComment Datenstruktur public class ...