RxDave

using System;
using System.Linq;

namespace Lab
{
  // THIS PROGRAM DOES NOT REQUIRE A REFERENCE TO RX
  class Program
  {
    static void Main()
    {

RxDave

using System;
using System.Reactive.Concurrency;
using System.Reactive.Linq;

namespace ConsoleApplication1
{
  class Program
  {
    static void Main()
    {

RxDave

Ix
{ left = 0, right = 2 }
{ left = 1, right = 3 }
{ left = 2, right = 4 }

Rx
{ left = 0, right = 1 }
{ left = 1, right = 2 }
{ left = 2, right = 3 }
{ left = 3, right = 4 }

RxDave

using System;
using System.Collections.Generic;
using System.Linq;
using System.Reactive.Linq;
using System.Threading;
using System.Threading.Tasks;

namespace Rxx.Labs
{
  // An async state machine example based on a simple FSM example found in the following Wikipedia article:

RxDave

using System;
using System.Reactive.Disposables;
using System.Reactive.Linq;

public class Foo : IDisposable
{
  private readonly CompositeDisposable subscriptions = new CompositeDisposable();
  
  // Called when the object is first created; e.g., a web service response is starting or a UI Control raises its loaded event.
  public void Initialize()