jminadeo

void Main()
{
	IObservable<Ticket> ticketObservable = Observable.Create((Func<IObserver<Ticket>, IDisposable>)TicketFactory.TicketSubscribe);
	
	using(IDisposable handle = ticketObservable.Subscribe(ticket => Console.WriteLine(ticket.ToString())))
	{
		Console.WriteLine("\nPress ENTER to unsubscribe...\n");
		Console.ReadLine();
	}
}