Browse by Tags
All Tags »
IObservable »
Beginner (
RSS)
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...
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 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...
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 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 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 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 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 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...
Rx - for beginners (part 3): IObservable Vs. IEnumerable this post is the 3rd in a series of posts about the new Reactive Framework ( Rx ). the series TOC can found here . this post will focus on how exactly the IObservable / IObserver mirror IEnumerable / IEnumerator . IEnumerator operations IEnumerable expose the following operations: Code Snippet public interface IEnumerator <T> : IDisposable , IEnumerator { T Current { get ; } } public interface { ...
Rx - for beginners TOC Reactive Framework ( Rx ) for beginners: What is Rx (Interactive Vs. Reactive, pull Vs. Push)? The Rx concept IObservable Vs. IEnumerable anonymous observer handler marble diagrams, select and where Merge expression Zip expression Combine Latest expression Hot Vs. Cold observable Concat expression ObserveOn RxJs Publish Buffer With Time Also available Code cartoon: Interactive Vs. Reactive Rx Contrib release תגים של Technorati: Iobservable , Iobserver...
Rx - Reactive Extension (part 2) this post is the second in a series of posts about the new Reactive Framework ( Rx ). the previous post discuss the concept of Rx (Reactive Framework Extension) , this post will focus on some basic practice. In this post we will create small WPF application that got images from different image feeds providers (the source code can be found here ). Application layout The application layout is described in the following diagram. the image data will...
Rx - R eactive E xtension (part 1) this post is the first in a series of posts about the new Reactive Framework ( Rx ). What is the Reactive Framework Extension? the Rx formalize the push based programming pattern. it is dealing with event like collection , in manner that can be describe as the mirroring of IEnumerable<T> . How does it mirror the IEnumerable<T>? the Rx framework most fundamental interface are, IObservable<T> which is mirroring IEnumerable<T>...