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

​

                            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 static void Main() {

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

    test.Subscribe((v) => {

        System.Threading.Thread.Sleep(1000);

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

    });

​

    Task.Run(()=>{

        test.OnNext(1);

        test.OnNext(2);});

    Task.Run(()=>{

        test.OnNext(3);

        test.OnNext(4);});    

​

    int count = 0;

    while(count < 5){

        System.Threading.Thread.Sleep(1000);

        count++;

    }

  }

}