Verarbeiten Sie viele kleine Aufgaben und halten Sie die Benutzeroberfläche ansprechbar

Verwendung von Observable.FromEvent anstelle von FromEventPattern und Vermeidung von Zeichenfolgenliteral-Ereignisnamen

Ich lerne mich in WinForms in Rx zurecht und habe folgenden Code:

Puffern Sie Daten vom Datenbankcursor, während die Benutzeroberfläche anspricht

Ich habe einen Datenbankkatalog, der gefüllt ist, und einen Cursor, der zum Abrufen von Objekten verwendet werden kann. Dieser Katalog kann natürlich sehr um...

So erhalten Sie ein IObservable von der Web-API zurück

Ich habe eine einfache Web-API, die eine beobachtbare zurückgibt. Ich verwende HttpClient, um das Observable zu erhalten, damit ich es abonnieren kann. Mein ...

ObserveOn und SubscribeOn - wo die Arbeit erledigt wird

Basierend auf dem Lesen dieser Frage:Was ist der Unterschied zwischen SubscribeOn und ObserveOn?

Gutes Beispiel für die Verwendung reaktiver Erweiterungen [closed]

Ich verstehe die Grundlagen von Rx. Ich habe Probleme damit, wie Sie dies tatsächlich jenseits akademischer Beispiele nutzen würden? Was sind einige gängige, einfache reale Szenarien, in denen Rx eine viel bessere Lösung ist als das, was wir ...

Caching-Problem mit WebClient / HttpClient

Ich entwickle einen Code, um alle 30 Sekunden einen Bitstamp-Börsenticker abzufragen. Dies ist ein Code, den ich habe: public IObservable<string> Stream(Uri way, WebClient wc) { Func<IObserver<string>, Task> Fun = async Observer => { var res = ...

Erweiterbarer historischer Stream und Live-Stream in Rx

Ich habe eine heiße beobachtbare, die ich normalerweise mit einer normalen implementiereSubject darunter, so dass interessenten einen live stream von benachrichtigungen abonnieren können. Jetzt möchte ich diesen Live-Stream beibehalten, aber ...

In welcher Beziehung stehen Reactive Framework, PLINQ, TPL und Parallel Extensions zueinander?

Spätestens seit der Veröffentlichung von .NET 4.0 scheint Microsoft große Anstrengungen unternommen zu haben, um die parallele und asynchrone Programmierung zu unterstützen, und es scheint, dass viele APIs und Bibliotheken in diesem Bereich ...

Verarbeiten von Empfangsereignissen in festen oder minimalen Intervallen

Ich habe eine Folge von Ereignissen, die alle 10-1000 ms auftreten. Ich abonniere diese Ereignisquelle, möchte sie jedoch in einem festen (oder minimalen) Intervall von 500 ms behandeln. Ich möchte auch EIN Ereignis gleichzeitig verarbeiten, ...