System.Reactive refers to the Reactive Extensions for .NET, also known as Rx, but it more specifically refers to the use of the System.Reactive.dll assembly, which is part of Rx. System.Reactive provides developers with a reactive programming model, as opposed to the traditional imperative ...

learn more… | top users | synonyms

2
votes
1answer
110 views

ReactiveUI And WPF - Reusing a value to update multiple properties

I've created my first ReactiveUI app in WPF. Simply, the user enters their full name in one textbox, and then the name gets split into its parts and displayed in the other textboxes. This is just an ...
5
votes
1answer
151 views

Finding local C# servers on a Java client using UDP and reactive extensions

This program uses UDP broadcast to find app servers on the local network. When a server receives a client broadcast, it sends a port (integer) to the client which will later be used to create a TCP ...
5
votes
2answers
92 views

BufferAggregate

In the ongoing saga of me rewriting functions that can be easily composed from existing Rx functions, I present my latest progeny: a bastard combination of Scan and Aggregate. The aim is to aggregate ...
3
votes
2answers
87 views

'Buffered' function for Rx

My application has a whole chain of Observables running through it, and recently I found that something was slowing down my (hot) source, but I couldn't work out where. Obviously, with everything ...
2
votes
0answers
358 views

Rx.net File watcher

I am new with Rx.net and tried to do a folder watcher that could send a notification when a new file is done being uploaded. Each instance check one and only one folder. Here are the steps to achieve ...
7
votes
1answer
2k views

A ViewModel using ReactiveUI 6 that loads and sends data

Most of the Rx Compelling Examples™ load and store data locally, which I don't find that Compelling. I spent some time coming up with how to best perform the following actions but want to make sure I ...
12
votes
1answer
394 views

Observable timer sequence

This question over on SO about how to call a function "later" using Rx led me to post the following ill-advised piece of code to solve the problem: ...
3
votes
1answer
1k views

CancellationToken and Reactive Extensions

I have a couple of calls that I need to cancel a subscription based on a CancellationToken. I saw How to cancel an observable sequence but I needed a more generic way. I created an extension method ...
3
votes
2answers
313 views

RX fluent subscribing to observables

I have three observables: ...
4
votes
1answer
137 views

Is this an ugly/incorrect usage of subscriptions?

Little backstory: I'm trying to write code that will read messages from INetworkConnection that the INetworkConnection publishes ...
2
votes
0answers
156 views

Polling, parsing, validating and handling data cleanly and efficiently

<edit: There's a major problem in the code. It is basically the one in the comment regarding backpressure. I'll rework the code within a a few days... It's time for a quick code review, good ...
11
votes
2answers
828 views

ReactiveUI and Rx background calculations with cancellation

I'm working on a WPF app which uses ReactiveUI and Rx, there's part of the workflow that watches two data sources (ReferenceData and ...
4
votes
0answers
252 views

F# and Rx code that throttles; can it be done without ref cells (and possibly with active patterns)?

I'm basically redoing a piece of reactive C# code posted in SO code in F#, please, see below. The translation is fairly literal, I've just written the infinite loop as a recursive function and ...
5
votes
1answer
126 views

Create an IObservable from a method

I have such a method that performs a long query search against some data. Task<List<SearchResult>> Search(string query){ ... } I have tried various ...
3
votes
1answer
231 views

pull things from lazy source till timeout is reached

I need to pull things from lazy source till timeout is reached in this fashion: ...
2
votes
1answer
3k views

Hot Observable of Change Tracking Events from SQL Server 2008 R2

After I found the Change Tracking feature in SQL Server, I thought that I would love to have this information in a stream. That lead me to RX, and Hot Observables. Did some reading, and came up with ...
6
votes
1answer
908 views

Can this reactive code be improved?

I have a view model that I'm migrating to RxUI. It exposes a collection of brokers along with a bool indicating whether there is a market (ie. at least one broker). ...
11
votes
1answer
994 views

Improve Parallel Cache with Reactive Extensions & Unity Interception

The requirement is to be able to cache method invocations made on a boundary layer (Services layer). I'm using Unity to inject the concrete implementation of the Service layer classes. The ...
3
votes
1answer
4k views

Implementation of a throttled ConcurrentQueue Rx observer

I was looking for a solution to allow me to rate limit the number of outgoing REST calls but preserved the order of queued elements so I found a rate limiter implementation and combined it with ...
5
votes
3answers
1k views

Is there an easier way to use Rx's GroupBy operator?

I'm just playing with the concept of GroupBy inside Rx. So, I wondered how hard it would be to write a console application that continuously reads lines, groups ...