system.reactive

1Hitze

1Antwort

FRP-Beispiel mit Ereignisschleife oder Thread-Pool

Meine Frage ist letztlich für Ruby rx-Bibliothek, obwohl jedes Beispiel in einer beliebigen Sprache gerne gewürdigt werden würde. Grundsätzlich möchte ich jede Operation auf eine vorhandene Ereignissc

system.reactive reactive-programming nonblocking frp event-loop 2016-04-06

---

1Hitze

2Antwort

Gebäude doppelt unendliches Wahlverhalten in RX

Das Problem ist, das doppelte Looping Verhalten mit RX zu emulieren: while True: try: token = get_token() while True: try: value = get_value_using_token(token)

python system.reactive observable rx-py 2016-04-06

---

2Hitze

1Antwort

Wenn Sie ein IConnectableObservable-Objekt entsorgen, wird OnComplete nicht gesendet.

Ich bin über ein Problem gestolpert, als ich versuchte, mit einem Worst-Case-Problem umzugehen. Das ist eine IConnectableObservable, die Abonnements hat, bevor es fertig ist. Ich habe ein künstliches

c# system.reactive 2016-04-08

---

2Hitze

1Antwort

Verarbeitet MailboxProcessor nur IObservable?

ich Typen einer Nachricht verarbeiten wollen Add x macht erinnern Programmnummer x Print macht es zu merkende Nummern drucken Warum würde ich dieses schreiben: open System type Message = | Add o

f# system.reactive actor 2016-04-08

---

0Hitze

2Antwort

Mehrere benutzerdefinierte Observables in RX zusammenfügen

Versuch, ein System zu modellieren, das Benachrichtigungen von mehreren Herausgebern mit RX sendet. Ich habe zwei benutzerdefinierte Schnittstellen ITopicObservable und ITopicObserver, um die Tatsache

linq system.reactive reactive-programming 2016-04-14

---

0Hitze

2Antwort

Wie Trigger auf einer Observable zu verwenden, um Trigger auf einem anderen zu unterdrücken?

Nehmen wir an, ich habe zwei Observables Obs1 und Obs2. Ich möchte, dass ein Trigger auf Obs1 den nachfolgenden Trigger auf Obs2 unterdrückt (Marmordiagramm unten). Wie mache ich das? Obs1---x---x--x-

c# .net system.reactive reactive-programming reactiveui 2016-04-18

---

3Hitze

1Antwort

Wie Timeout-Verhalten mit TestScheduler zu erreichen?

Ich habe die folgende Hilfsmethode erstellt mit Test Observablen zu unterstützen: public static void ExecuteObservableTest<T>(IObservable<T> observable, Action action, Action assert, bool expectTimeou

c# unit-testing system.reactive scheduler reactive-programming 2016-04-18

---

1Hitze

1Antwort

Warum wird WhenAnyValue Observable im Abonnement ausgelöst?

Ich habe folgendes Dummy Ansicht Modell: public class DummyViewModel : ReactiveObject { internal DummyViewModel() { ItemChanged.Subscribe(_ => Console.WriteLine()); } publi

c# mvvm system.reactive reactive-programming reactiveui 2016-04-18

---

0Hitze

1Antwort

Aufbau eines Sensorüberwachungssystems mit RX

Siehe Hintergrund Merging multiple custom observables in RX. Mein Szenario ist, dass ich eine Reihe von beliebigen Sensoren (Hardware) habe. Ich habe einige steckbare Module geschrieben, die an diese

linq system.reactive reactive-programming 2016-04-19

---

4Hitze

1Antwort

Disposable kombinierte Observables von Ereignissen

Ich schreibe einen Socket-Server, der jede Nachricht von jedem Client behandelt sollte, der damit verbunden ist. Alle Nachrichten sind in einer beobachtbaren Reihenfolge eingereiht, so dass sie abonni

c# system.reactive 2016-04-20

---