Top "System.reactive" questions

System.

How to use Observable.FromEvent instead of FromEventPattern and avoid string literal event names

I'm learning my way around Rx within WinForms, and have the following code: // Create an observable from key presses, grouped …

.net winforms system.reactive
Howto call back async function from rx subscribe?

I would like to call back an async function within an Rx subscription. E.g. like that: public class Consumer { …

c# asynchronous system.reactive reactive-programming
Immediate debounce in Rx

I am looking an operator to debounce a series of event, let us say user's click. The input and output …

rx-java rxjs system.reactive debounce
EventBus/PubSub vs (reactive extensions) RX with respect to code clarity in a single threaded application

Currently, I am using an EventBus/PubSub architecture/pattern with Scala (and JavaFX) to implement a simple note organizing app (…

event-handling system.reactive reactive-programming event-bus rx-java
Implementing IObservable<T> from scratch

The Reactive Extensions come with a lot of helper methods for turning existing events and asynchronous operations into observables but …

c# system.reactive
Reactive Extensions (Rx) + MVVM =?

One of the main examples being used to explain the power of Reactive Extensions (Rx) is combining existing mouse events …

mvvm system.reactive reactive-programming
Is there Rx.NET for .NET Core?

Found https://github.com/Reactive-Extensions/Rx.NET/issues/148, but I could not figure out the bottom line - where is …

c# system.reactive .net-core
IObservable vs Plain Events or Why Should I use IObservable?

Microsoft introduced the IObservable<T> interface to the BCL with .NET Framework 4, and I thought, "Great, finally, I …

events design-patterns .net-4.0 system.reactive
TPL vs Reactive Framework

When would one choose to use Rx over TPL or are the 2 frameworks orthogonal? From what I understand Rx is …

c# .net task-parallel-library system.reactive
RX vs messaging queues like rabbitmq or zeromq?

I'm quite new to these high level concurrency paradigms, and I've started using the scala RX bindings. So I'm trying …

rabbitmq system.reactive zeromq reactive-programming