System.Reactive bezieht sich auf die Reactive Extensions für .NET, auch bekannt als Rx. Rx bietet Entwicklern ein reaktives Programmiermodell über die generische IObservable -Schnittstelle, im Gegensatz zum traditionellen imperativen Programmiermodell oder den anderen reaktiven Programmiermodellen, die sich ausschließlich auf .NET Events oder spezifische APIs stützen.
Die neuen IObservable / IObserver-Frameworks in der System.Reactive-Bibliothek in .NET 4.0 sind sehr aufregend (siehe dies und dieser Link).
Es ist vielleicht zu früh, um darüber zu spekulieren, aber wird es auch ein (aus Mangel an einem b...
Angenommen, ich verwende die folgende Schnittstelle (vorausgesetzt, wir können unsere Implementierung nicht ändern, um IObservable<T> und IProperty<T> zu erhalten).
%Vor%
Ich versuche, die Sammlung von T s zu beobachten,...
Es gab ziemlich viel Hype um das neue Reaktives Framework in .NET 4.0. Während ich denke, dass ich sein grundlegendes Konzept überlebt habe, bin ich nicht vollständig verkauft, dass es so nützlich ist. Können Sie sich ein gutes Beispiel (das h...
Dies ist eine Frage zur Verwendung von Reaktive Erweiterungen (Rx) in einem bestimmten ereignisbezogenen Szenario.
Ziel ist es, eine Anzahl von Klassen zu nehmen, die ein Ereignis auslösen
Und sammeln Sie sie in einem IObservable , das v...
Ich habe einen RX-Producer, der einen Stream von Strings wie folgt erzeugt (vereinfachte Version des realen Streams):
A1 A2 A3 B1 B2 C1 C2 C3 C4 C5 C6....
Der Strom ist endlos, aber geordnet. Nachdem die Strings, die mit A ausgehen,...
Wie kann ich den Puffer auf einem ReplaySubject löschen?
In regelmäßigen Abständen muss ich den Puffer löschen (in meinem Fall ein Ereignis am Ende des Tages), um zu verhindern, dass das ReplaySubject ständig wächst und schließlich den gesamt...
Es gibt einen Port von Rx namens mono-reactive , der ein MonoTouch-Projekt enthält, aber der Autor vor zehn Tagen angekündigt gibt er das Projekt zugunsten der Open-Source-Implementierung von Microsoft auf:
Ich verkünde glücklich, dass...
Task<T>.ContinueWith hat das gleiche grundlegende Konzept wie IObservable<T>.Subscribe . Sie sind ähnlich genug für Reactive Extension, um eine Konvertierungserweiterungsmethode bereitzustellen. Da IObservable<T> Teil d...
Ich bin etwas neu bei Rx.NET. Ist es möglich, eine Ausnahme zu erfassen, die von einem der Abonnenten ausgelöst werden kann? Nimm folgendes ...
%Vor%
Gegenwärtig bin ich pro Abonnement mit einer der folgenden Instanzen beschäftigt. Die Imple...
Observable.Concat ist eine Implementierung, die Observables verbindet, aber die zweite IObservable<T> erstellt nur dann die Subskription, wenn die erste abgeschlossen ist.
Ссылка
Gibt es eine Implementierung eines "HotConcat"...