The system.reactive tag has no wiki summary.
8
votes
1answer
197 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 ...
4
votes
1answer
166 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). In addition, it has a property for ...
4
votes
3answers
318 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 them by similar words and just prints ...
3
votes
1answer
823 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 ...
2
votes
1answer
410 views
Is this a good example of Reactive Extensions? How can I make this better?
using System;
using System.Collections.Generic;
using System.Linq;
using System.Reactive.Linq;
using System.Threading;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using RestSharp;
namespace ...
2
votes
0answers
63 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:
var results = lazySource.SelectMany(item =>
{
//processing goes here
}).Pull(timeout: TimeSpan.FromSeconds(5), ...
0
votes
1answer
145 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 ...
0
votes
0answers
54 views
Improve my reactive code (ping/pong sample)
I'm starting with the reactive framework, how can I improve my logic?
The way it is doing the code below, I can not add parameters in the composition, e.g.: Where, Syncronize, OnError.. How can I ...
