Rx Contrib has new version (1.3) Release Notes - Bug Fix - BufferWithTimeOrCount with flexible time period enabled when ever the time period elapsed it will use the lamda for getting the next period this feature is a join effort of Amir Shitrit and Bnaya Eshet Code Snippet IObservable < long > obs = Observable .Interval( TimeSpan .FromMilliseconds(10)); var bufferQueue = obs.BufferWithTimeOrCount(() => TimeSpan .FromMilliseconds(500), 10); you can download the source or binaries from...
Performance tips recently I was working on the Reactive Queue (which is part of the Rx Contrib ). the requirement for the Reactive Queue was to to achieve the highest throughput possible for each queue provider ( 2,000,000 messages of 500 byte per second using Concurrent Queue provider running on simple quad server ). while working on this project I was encounter the the following performance hits: 1. ManualResetEventSlim there is a big difference between using the old ManualResetEvent Vs...
Rx Contrib release V1 Rx Contrib is ongoing effort of community extensions for Rx . you can can find the project at http://rxcontrib.codeplex.com/ Current features are: ReactiveQueue : is ISubject that does not loose values if there are no subscribers . The reactive queue is using the IQueueAdapter for injecting concrete queue adapters (which mean that it can be extend to support other queues). the out of the box implementation is using ConcurrentQueue which have extreme throughput...