Browse by Tags
All Tags »
SELA »
Rx (
RSS)
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 - SP1 Rx release is having it first service pack. The Service Pack release doesn't include any new API-level functionality and fixes a few minor bugs (all of which were already fixed in the Experimental Releases in the v1.1 band): Scheduler.TaskPool now guarantees the use of the task pool. See this forum post for more info. SkipUntil now propagates errors of the source sequence, even when the "until" sequence hasn't fired yet. ToQbservable now accepts an IScheduler parameter...
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...
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 - User Group session this is just a reminder, tomorrow (Wednesday 2011-11-22) I'm giving Rx (Reactive Extension) session at Microsoft Israel user group. if you want to hear about Rx you can register at here . on the other hand if you want a full day tutorial on TPL 4.5 you can resister to Sela Developer Practice (this one is not for free). Yaniv Rodenski and I will give 2 days tutorials about TPL and Async programing in .NET 4.5. the first day is a walk through TPL 4 and the new async...
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 .
More Posts
Next page »