101 Rx Samples - a work in progress - Reactive Framework (Rx) Wiki

101 Rx Samples - a work in progress - Reactive Framework (Rx) Wiki

Table of Contents

Asynchronous Background Operations

Start - Run Code Asynchronously

Run a method asynchronously on demand

CombineLatest - Parallel Execution

Create With Disposable & Scheduler - Canceling an asynchronous operation

Observation Operators

Observing an Event - Simple

Observing an Event - Simple (expanded)

Observing MouseMove in Silverlight

Observing an Event - Generic

Observing an Event - Non-Generic

Observing an Asynchronous Operation

Observing a Generic IEnumerable

Observing a Non-Generic IEnumerable - Single Type

Observing a Non-Generic IEnumerable - Multiple Types

Observing the Passing of Time

Restriction Operators

Where - Simple

Where - Drilldown

Projection Operators

Select - Simple

Select - Transformation

Select - Indexed

Grouping

Group By - Simple

Time-Related Operators

Buffer - Simple

Delay - Simple

Interval - Simple

Sample - Simple

Throttle - Simple

Interval - With TimeInterval() - Simple

Interval - With TimeInterval() - Remove

Timeout - Simple

Timer - Simple

Timestamp - Simple

Timestamp - Remove

Window and Joins

Window

GroupJoin - Joins two streams matching by one of their attributes

Range

Range - Prints from 1 to 10.

Generate

Generate - simple

ISubject<T> and ISubject<T1, T2>

Ping Pong Actor Model with ISubject<T1, T2>

Combination Operators

Merge

Publish - Sharing a subscription with multiple Observers

Zip

CombineLatest

Concat - cold observable

Concat - hot observable

Make your class native to IObservable<T>

Use Subject<T> as backend for IObservable<T>

Read full article from 101 Rx Samples - a work in progress - Reactive Framework (Rx) Wiki