Writing Your First Rx Statement
Introduction In my first blog post on Reactive Extensions (Rx), Introduction to Reactive Extensions , I mentioned that there are several ways in which you can create an IObservable<T>. The most fundamental way to create an IObservale<T> is be using the Observable.Create<TSource>() method. At first glance this method is a bit confusing but once you know how to implement it, it becomes very powerful. You First Rx Statement In this tutorial I will build a Windows console application that will make an asynchronous web call to the Twitter API using the WebClient.DownloadStringAsync() and Rx. I begin by creating a new console application called SampleRxApp. Next, I add the appropriate Rx reference. For this, I use Nuget to add a reference to Rx-Main. Once I have added necessary Rx library, I add the following using statement to the top of my Program.cs file. using System; using System.Net; using...