Suchergebnisse für Anfrage "system.reactive"
Lies den kontinuierlichen Bytestream mit TcpClient und Reactive Extensions aus dem Stream
Betrachten Sie den folgenden Code: internal class Program { private static void Main(string[] args) { var client = new TcpClient(); client.ConnectAsync("localhost", 7105).Wait(); var stream = client.GetStream(); var observable = ...
Drosselungsereignisse und Sperrmethoden
Stellen wir uns vor, ich hätte so etwas: <TextBox Text="{Binding Text, Mode=TwoWay}" />Und so ähnlich: public class MyViewModel : INotifyPropertyChanged { public MyViewModel() { // run DoWork() when this.Text ...
EventBus / PubSub vs (reaktive Erweiterungen) RX hinsichtlich der Code-Klarheit in einer Anwendung mit einem Thread
Zur Zeit benutze ich einen EventBus /PubSub [http://en.wikipedia.org/wiki/Publish%E2%80%93subscribe_pattern]Architektur / Muster mit Scala (und JavaFX) zur Implementierung einer einfachen Notiz-Organisations-App (ähnlich einem Evernote-Client mit ...
So „rekonstruieren“ Sie Datenzeilen, die mit Rx aus SerialPort gelesen wurden
Ich lerne gerade Rx und habe versucht, mithilfe von SerialPort einen "NMEA-Satzleser" von einem GPS-Gerät aus zu implementieren. Die Tatsache, dass es sich um GPS-Daten handelt, ist für die Frage von geringerer Bedeutung. Lassen Sie uns also ...
Warum wird der OnError-Rückruf nie aufgerufen, wenn er vom angegebenen Teilnehmer abgeworfen wird?
Bitte beachten Sie den folgenden Komponententest: using System; using System.Reactive.Linq; using System.Threading; using System.Threading.Tasks; using Microsoft.VisualStudio.TestTools.UnitTesting; namespace UnitTests { [TestClass] public class ...
Was ist der praktische Unterschied zwischen all diesen Reactive Observable-Erweiterungen?
Was ist bei einem bestimmten BehaviorSubject der praktische Unterschied zwischen dem Aufrufen all dieser verschiedenen Funktionen? Zuerst()Zuletzt()LatestValue ()MostRecentValue ()NextValue ()Single()Nimm 1) Vorausgesetzt, ich verstehe es ...
Wie erwarte ich eine Antwort von einem RX-Betreff, ohne eine Rennbedingung einzuführen?
Ich habe einen Dienst, mit dem ein Anrufer Befehle senden und Antworten asynchron empfangen kann. In einer realen Anwendung sind diese Aktionen weitgehend getrennt (einige Aktionen senden einen Befehl, und die Antworten werden unabhängig ...
Sollte IObservable Ereignissen vorgezogen werden, wenn Benachrichtigungen in einer auf .NET 4+ ausgerichteten Bibliothek verfügbar gemacht werden?
Ich habe eine .NET-Bibliothek, die als Teil eines Objektmodells Benachrichtigungen über bestimmte Vorkommen sendet. Es scheint mir, dass die wichtigstenProfis vonVeranstaltungensind Annäherungsmöglichkeiten für Anfänger (und Einfachheit in ...
Reaktive Nebenstellen Anruf warten
Ich möchte für jedes einen asynchronen Anruf durchführenVeranstaltung durch eine Reactive Extensions Observable ausgelöst. Ich versuche auch, alles synchron zu halten, da der asynchrone Aufruf beendet werden soll, bevor das nächste ...
Ist es mit MongoDB möglich, Benachrichtigungen über Änderungen von Drittanbietern über .NET Reactive Extensions (RX) zu erhalten?
Ich frage mich, ob jemand weiß, ob es möglich ist, Live-Benachrichtigungen über Änderungen an einer MongoDB-Datenbank über Reactive Extensions (RX) in C # zu erhalten. Dies würde bedeuten, dass jeder Dritte die MongoDB-Datenbank bearbeiten und ...