Browse by Tags
All Tags »
Parallel »
Reactive Extension (
RSS)
The 3rd day of the SDP was over and I want to thanks all the attendants. my yesterday session was about C# 5 async and await . today I will have a full day tutorial on Rx and TPL Dataflow . you can download the demo code and also the presentation for second and third days from here (the link is also having the demo code for today's sessions). anyway, I also want to recommend 2of yesterday session. if you were attend at the conference you should have an access to the sessions video page. first...
Open House at Microsoft yesterday I was lecturing at Microsoft about VS 2012, .NET 4.5, async/await, Rx and TPL Dataflow. there was 90 people attended and I hope that everybody has learn something new. the code sample for this lecture available here .
SDP 2012 - Day 2 the SDP 2012 conference has day 2 had completed. I was speaking about async / await , Rx and TPL Dataflow . you can find the materials for my lecture in here . I will give the same lecture on Wednesday next week, there is a chance that some place is still available, so if you are interesting, you can check it with Sela Marketing .
Visual Rx - Part 6 this post is part of the Visual Rx series and it will focus on Visual Rx Viewer Side Extensibility . this post is dealing with advance topic, you may want to read other post on this series before reading this one. this post refer to version 2.0.20.622.60 or higher (the extensibility model was simplify at this version). Visual Rx support extension via plug-ins bundle contract. a plug-ins bundle contains: General information about the package (like title and description), Publisher...
Visual Rx Version 2.0.20622.60 I have release a new version of Visual Rx just before my fight to the Build conference. the version support .Net 4.5 and is having a new plug-in model. this post will be follow by a post about writing plug-ins for the Visual Rx. for the client side it is recommended to use the Nuget package (write visualrx into the Nuget search box). if you want to learn more about .Net 4.5 parallelism, Rx and Tpl Dataflow you can check out the Sela developer practice conference...
Sela conferences (SDP) is coming near (25-29/3/2012). you can check the following link for all the SDP's tutorials and sessions http://www.sela.co.il/s/SDP2012/index.html . I will present 2 full-day tutorials (Yaniv Rodenski will join me on the first one). the first day Introduction to the Task Parallel Library is a full TPL 4 day which will give you a solid knowledge, HowTo and Consideration about building parallel application using the TPL library. at the end of this day we will...
Rx - DistinctUntilChanged this post will focus on the simple yet very useful DistinctUntilChanged operator. sometimes a datum stream may produce the same value for a while, you can see it in stock exchange stream the value of specific stock may be steady for a while. the observer can reduce its computation level by ignoring a repeatable value (sequential repeatable value, for none sequential you can use the Distinct operator). the DistinctUntilChanged is having the following overloads: Code Snippet...
Rx - Aggregate vs. Scan this post will focus on 2 Rx operators Aggregate and Scan . both Aggregate and Scan are dealing with event stream accumulation , the only difference is that Aggregate produce single result (upon the stream completion) and Scan present an ongoing runtime accumulation which react for each OnNext . both operators has 2 overloads with the same signature: Code Snippet IObservable <TSource> Aggregate<TSource>( this IObservable <TSource> source, Func <TSource...
Rx - Exception Handling this post will discuss exception handling within the Rx arena. handling event stream exception is not trivial, for example observable should delegate exception to its subscribers though the OnError operation and cancel the subscription . on the other hand the subscriber may want to response OnError state by renewing its subscription or fallback to alternative stream . it is true that the Rx design guidelines suggest that faulted stream should not continue to produce data,...
Rx - Sample this post will focus on the Rx Sample operator. the Sample operation does sampling the observable stream and forward less intensive data stream of the sampled datum. it can be prove very useful for scenario like handling accelerometer stream which can produce 60 value per second, in some cases we don't need such intensity and our machine resources may be happier to handle only 10 value per seconds. the same may be apply to video stream analytics and many other scenario. this is how...
Rx - Window continuing with the Rx series, this post will discuss the Window operator. in previous post I was discussing the Buffer operator which enable buffering of Rx datum stream into chunks. has good and useful as the Buffer operator is, it doesn't nail up every single scenario. let consider a scenario of tracing the highest and lower value within a time period . for example hourly tracking of a service monitoring which produce values every second. technically we can use the Buffer operator...
Rx - Buffer this post is on of a series of post about Rx (Reactive Extension). in this one I will discuss the Buffer operator. no doubt that one of the most useful Rx operator is the Buffer . the Buffer operator enable to reduce a throughput pressure and gain better utilization of our resources. let take a scenario of monitoring data stream and persist the datum into database (or send it through a network boundaries). assuming the datum rate is 1 per millisecond, databases does not typically design...