system.reactive

1Hitze

1Antwort

Rx kombiniert viele Streams durch Beitritt zu einer Eigenschaft

Ich versuche, eine beliebige Anzahl von Streams in Rx, zip, wo Elemente entsprechen, aber möglicherweise außerhalb der Reihenfolge verarbeitet werden. Die Elemente jedes Streams haben eine Kennung, mi

c# system.reactive reactive-programming 2016-05-17

---

2Hitze

3Antwort

Begrenzen gleichzeitiger Anfragen mit Rx und SelectMany

Ich habe eine Liste von URLs von Seiten, die ich gleichzeitig herunterladen möchte mit HttpClient. Die Liste der URLs groß sein kann (100 oder mehr!) Ich habe derzeit haben diesen Code: var urls = new

c# .net concurrency system.reactive reactive-programming 2016-05-20

---

2Hitze

2Antwort

Wie mit der async-Methode in Rx abonnieren?

ich folgenden Code haben: IObservable<Data> _source; ... _source.Subscribe(StoreToDatabase); private async Task StoreToDatabase(Data data) { await dbstuff(data); } Dies ist jedoch nicht

c# async-await system.reactive 2016-05-24

---

2Hitze

1Antwort

C# Reactive Extensions - Speicherverwaltung und die Distinct Operator

Beispielcode: public static IObservable<Order> ObserveOrders(this IProxy proxy,IEqualityComparer<Order> distinctPerDayComparer) { return Observable.FromEvent<Order>(ev => proxy.OrderUpdated

c# system.reactive 2016-05-25

---

0Hitze

3Antwort

Reihenfolge der Objekte mit Auflistung in eine flache Reihenfolge ändern

Ich habe eine Sequenz von Ereignissen des Typs A. A enthält eine Aufzählung von Datenobjekten B. Ich möchte Sequenz A in C zuordnen, so dass es eine flache Sequenz ist von B. Wie kann ich das tun? pub

c# system.reactive reactive-programming 2016-05-26

---

1Hitze

2Antwort

Unerwartetes Verhalten bei RX Subscribe - subscribe() & wartet auf Abschluss der Aufgabe: ~ |

Ich habe den folgenden Code-Block, der beim Ausführen erwartet, dass ich die blockierende Sammlung konsumieren und innerhalb der Subscribe() Aktion einige asynchrone Aktivitäten ausführen soll, bevor

c# async-await system.reactive 2016-06-05

---

0Hitze

1Antwort

Wie blockiere ich den aktuellen Thread, bis OnComplete ohne die Verwendung traditioneller Threading-Primitive fertig ist?

Wie blockiere ich den aktuellen Thread, bis der OnComplete -Handler meines Beobachters beendet ist, ohne Threading-Primitive zu verwenden? Hier ist mein Code. Ich möchte, dass die Console.WriteLine("P

system.reactive 2016-06-14

---

2Hitze

3Antwort

Was wäre eine echte Welt Verwendung oder Notwendigkeit der Rx-Operator nie?

Warum würden Sie jemals ein Observable abonnieren oder gar erstellen, das niemals etwas bringt, nicht einmal einen Fehler, noch eine Vervollständigung?

system.reactive 2016-06-14

---

0Hitze

1Antwort

Beobachten zurück zum aktuellen Thread

Ich versuche, eine Observable auf einen neuen Thread zu planen und das Ergebnis zurück auf den aktuellen Thread zu bekommen. namespace ConsoleApplication1 { class Program { static voi

c# concurrency system.reactive 2016-06-16

---

0Hitze

2Antwort

Rx Cache - Replay Operator löscht

Ich bin den folgenden Code aus hier mit - sieht aus wie ein Problem zu mir in die "Replay-Cache" Clearing https://gist.github.com/leeoades/4115023 Wenn ich ändere den folgenden Aufruf und Code So sehe

c# .net system.reactive 2016-05-18

---