Browse by Tags
All Tags »
Reactive Extensions »
IObserver (
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 at .NET User Group if you happens to be in Israel at November 23, and like to hear lecture about Rx , you are more than welcome to register to my Rx lecture at the Israel .NET User Group. http://isrmsdn-net-nov2011.eventbrite.com/ The Reactive Extensions (Rx) is a library for composing asynchronous and event-based programs using observable sequences and LINQ-style query operators. Using Rx, developers represent asynchronous data streams with Observables , query asynchronous data streams using...
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...
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 .
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...
Rx - for beginners (part 14): time based buffering this post is the 14th in a series of posts about the new Reactive Framework ( Rx ). the series TOC can found here . in this post we will focus on the BufferWithTime operator. the code for this post available here . What does BufferWithTime operator do? the buffer with time operator is buffering values that occurs within specific time windows , and then publish the buffered values whenever the time period ends . Marble diagram...
More Posts
Next page »