public static void Main()
Console.WriteLine("Hello World");
public void NonBlocking_event_driven()
var ob = Observable.Create<string>(observer =>
var timer = new System.Timers.Timer();
timer.Elapsed += (s, e) => observer.OnNext("tick");
timer.Elapsed += OnTimerElapsed;
var subscription = ob.Subscribe(Console.WriteLine);
private void OnTimerElapsed(object sender, ElapsedEventArgs e)
Console.WriteLine(e.SignalTime);