Bnaya Eshet

New contribution for Rx contrib

  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

Performance tips

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 - for beginners (part 14): time based buffering

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...

Rx - for beginners (part 13): Publish (broadcast to many subscribers)

Rx - for beginners (part 13): Publish (broadcast to many subscribers) this post is the 13th 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 Publish operator.   the code for this post available here .   let guess how many times the select statement will be invoke for the following code, the underline stream will produce 2 value (0, 1) ? Code Snippet IObservable < long > observableRoot = Observable .Interval...

Rx - for beginners (part 12): RxJs

this post is the 11th in a series of posts about the new Reactive Framework ( Rx ). the series TOC can found here . in this post we will focus on Rx for JavaScript .   the recently the Rx team release JavaScript library that capable to get observable stream from events.   for example the syntax for mouse move event will be: var mouseMove = Rx.Observable.FromJQueryEvent($(document), "mousemove" );   all you have to do in order of using this library is to rx.js which is less...

Rx - for beginners (part 11): ObserveOn

Rx - for beginners (part 11): ObserveOn this post is the 11th 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 ObserveOn…   the code sample for this post can be found here .   sometime it is important that the observation will occurs on specific thread . for example GUI application like ( WinForm , WPF and Silverlight ) throw exception whenever UI component accessed on thread different than its creation thread...

Recommendation

Recommendation   this is a post recommendation about using Rx framework with WPF events , I'm recommending this post from bobby's blog , the post is demonstrating the use of creating observable stream from WPF event. it is a short post with nice little code sample . bobby did a real good job by wrapping the observable event ( Observable.FromEvent ) into more human readable format (using T4 template).

Rx - for beginners (part 10): Concat expression

Rx - for beginners (part 10): Concat expression this post is the 10th 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 Concat expression.   the code for this post can be download from here .   What does it do? the Concat expression is used to concatenate one Observable stream into the end of another Observable stream. once the first Observable stream is completed the the concat stream will be immediate subscribed...

New release of Rx

New release of Rx is available for download. the Rx team has new release for .NET 3.5, .NET 4.0 RC, and Silverlight 3. you can download the library from here .   the release includes some API changes, some APIs has moved into different assemblies, performance and bug fixes.   Highlights Moved IObservable & IObserver to seperate assembly: System.Observable.dll . Moved Schedulers to System.CoreEx.dll . Moved schedulers to System.Concurrency . Added schedulers to subjects . Removed deadlocks...

Rx - for beginners (part 9): Hot Vs. Cold observable

Rx - for beginners (part 9): Hot Vs. Cold observable this post is the 9th 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 Hot Vs. Cold observable stream.   the code for this post can be download from here .   If a tree falls in a forest and no one is around to hear it, does it make a sound? if it do make a sound when nobody observed it, we should mark it as hot , otherwise it should be marked as cold .  ...

Rx - for beginners (part 8): Combine Latest expression

Rx - for beginners (part 8): Combine Latest expression this post is the 8th 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 Combine Latest expression. the code for this post can be download from here .   What does it do? like the zip expression the Combine Latest expression is used to synchronize 2 IObservable streams into single IObservable stream. unlike the zip expression the Combine Latest doesn't...

Rx - for beginners (part 7): Zip expression

Rx - for beginners (part 7): Zip expression this post is the 7th 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 Zip expression. the code for this post can be download from here .   What does it do? the zip expression is used to synchronize 2 IObservable streams into single IObservable stream.   How does it do it? it is taking the first observed value on either of the stream and wait for value from the...

Rx - for beginners (part 6): Merge expression

Rx - for beginners (part 6): Merge expression this post is the 6th 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 Merge expression.   What does it do? the merge expression is used to merge multiple IObservable streams into single IObservable streams. the marble diagrams of merge expression will look as follow: each value on the source streams is project into the result stream until all the source streams complete...

Rx - for beginners (part 5): marble diagrams, select and where

Rx - for beginners (part 5): marble diagrams, select and where this post is the 5th in a series of posts about the new Reactive Framework ( Rx ). the series TOC can found here .   this post will focus on marble diagrams which is used for visualizing IObservable stream . on this post we will visualize the select and where clause, while in the upcoming posts we will discuss other operations that can be used to upon IObservable streams .   the code sample for this post is available here ....

Rx - for beginners (part 4): anonymous observer handler

Rx - for beginners (part 4): anonymous observer handler this post is the 4th in a series of posts about the new Reactive Framework ( Rx ). the series TOC can found here .   this post will focus on anonymous observer handler. the code sample for this post can be download from here .   Anonymous Observer as we mention on the previous posts, IObserver is used as a callback interface which can be subscribe to the IObservable , but this is a bit of overkill, when what we subscribe is relatively...