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

​

                            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 {

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

    public int Test { set { test.OnNext(value); } }

  public void Main() {

    test.Subscribe((v) => {

        //System.Threading.Thread.Sleep(1000);

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

    });

​

    Task.Run(()=>{

        Test = 1;

        Test = 2;});

    Task.Run(()=>{

        Test =3;

        Test =4;});    

​

    int count = 0;

    while(count < 5){

        //System.Threading.Thread.Sleep(1000);

        count++;

    }

  }

}