using System;

using System.Reactive.Linq;

using System.Reactive.Disposables;

​

public class Program

{

    public static void Main()

    {

        var observable = Observable

            .Create<int>(o =>

            {

                o.OnNext(13);

                o.OnCompleted(); // Commenting this line alters the observed behavior

                return Disposable.Empty;

            })

            .Do(x => Console.WriteLine("Producer generated:" + x))

            .Finally(() => Console.WriteLine("Producer finished"))

            .Publish()

            .RefCount()

            .Do(x => Console.WriteLine("Consumer received #" + x))

            .Finally(() => Console.WriteLine("Consumer finished"));

​

        observable.Subscribe().Dispose();

        observable.Subscribe().Dispose();

    }

}