/******************************************************************************

​

                            Online C# Compiler.

                Code, Compile, Run and Debug C# program online.

Write your code in this editor and press "Run" button to execute it.

​

*******************************************************************************/

​

using System;

​

using System.Reactive.Linq;

using System.Threading.Tasks;

using System.Reactive.Subjects;

​

public class Program {

​

    static BehaviorSubject<int> test = new BehaviorSubject<int>(0);

    static int TestUpdate { set { test.OnNext(value); } }

    public static void Main() {

        test.Subscribe((v) => {

            System.Threading.Thread.Sleep(1000);

            Console.WriteLine("Heard: " + v);

        });

​

        Task.Run(()=>{

            TestUpdate = 1;

            TestUpdate = 2;});

​

        Task.Run(()=>{

            TestUpdate = 3;

            TestUpdate = 4;});    

​

        int count = 0;

        while(count < 5){

            System.Threading.Thread.Sleep(1000);

            count++;

        }

  }

}