Browse by Tags
All Tags »
Reactive Extensions »
SELA (
RSS)
the 2011 SDP conference has just come to end. and we want to thanks all attendants. we have spoken about TPL and what’s new in TPL 4.5 , Aysnc and await , Rx (Reactive Extension) and TPL Dataflow . the material for the our sessions is available here . the link contain the material for both the first and second day (code samples). links: RxContrib project , Rxx Project , TPL Dataflow
New version of Rx Contrib I have release new version of Rx Contrib it is support both the Rx release (1.0.10621) and Rx experimental version (1.1.10621.0). the Profile contract dll has renamed to System.Reactive.Contrib.Profile.Contracts and the profiler visualizer has improved.
SDP Agenda - TPL and Beyond the SDP conference is taking place next week and we have close the final agenda. the first day ( Introduction to TPL ) will include: TPL introduction What's new in TPL 4.5 the second day ( Parallel Programming: One Step Beyond ) will include: Async (new syntax for .NET 4.5) Rx - Reactive Extension TPL Dataflow
Rx - User Group Summary I want to thanks the participant of User Group . a subject that was continually raising during the session was the Rx Remote (cloud) story, as I said this is something that the Rx team is working on. we can see some early adoption of the Idea in open source like Rxx , but the library's API doesn't there yet. today we still do not have a real simple scenario of remote scheduler (over Remoting / Wcf / Azure ), and even more important remote IQbservable that will evaluate...
Rx - User Group Materials Today I'm taking about Rx in the Israel .NET User Group . I have decide to upload the session material in advance. you can get session materials here . I hope that everyone will find the session beneficial and interesting.
Rx Contrib - new release finally I got the time to update the Rx Contrib with the Rx release bits. the release contain couple of new features and refactoring. This a snapshot of what's in the release: The ReactiveQueue was refactor to QueueSubject . The static Create method overload has changed: now it is having a flags which can define it’s behaviors, a-sync and whether to publish performance counter (currently ETW counter are not enabled) , It also can be configure to run synchronously...
Rx Release the Rx ( Reactive Extension ) is finally shipped, and it seem a great time for speaking about the Rx future . Rx was started as in process technology, but with the addition of the IQbservable (the Rx complementary of IQueryable ), Rx is breaking the process boundary. actually this is the same story as for IEnumerable and IQueryable , IQueryable broke the process boundary of the IEnumerable execution. using IQueryable we can translate the IEnumerable into expression tree which will...
yesterday I and Yaniv Rodenski had complete our second day tutorial about the TPL (Task Parallel Library), Async CTP , Rx , Tpl Dataflow and Windows HPC . we want to thanks all attendants'. the material of the days will be available shortly on the web. in the near future I will start new post series about the new Tpl Dataflow library and features of the Async CTP .
Rx - Tool recommending One of my colleague ( Taras Naumtsev ) has inform me about a very cool Rx Vistalizator tool called RxSandbox which I'm warmly recommending. the tool is an excellent resource for learning about Rx features . Marcin Najder did great job and you can enjoy it. see more at http://mnajder.blogspot.com/2010/03/rxsandbox-v1.html .
SELA Group was having a live broadcast on the SDP conference content, if you happens to be at Israel at between the 13-16.3 and considering to attend the conference, the on demand recording can help you to choose which session best suit you . the SDP agenda site: http://www.sela.co.il/s/sdp/_new/practice2011.html my talk about the Parallel tutorial day and MEF session: http://scc.sela.co.il/scc/pages/showlecture/showlecture.aspx?lectureid=487 .
Yuval Mazor has contrib CCR provider for the Reactive Queue . read more here http://blogs.microsoft.co.il/blogs/yuvmaz/archive/2010/05/19/ccr-provider-available-for-the-reactive-queue.aspx
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...
you can download the new version from here . the drop include the following changes: Build 1.0.2441.0 04/14/2010 Rx .NET Added BufferWithTimeOrCount. Changed ForkJoin to take the last value from each source. Peformed FxCop naming cleanup work. Removed FutureDisposable in favor of MutableDisposable. Added Sequential operators like While, If, Case etc… Added SkipLast & TakeLast. Made fixes to CurrentThreadScheduler & NewThreadScheduler. Added Scan0. Made Sample fire last sample area...
More Posts
Next page »