P. riedl emwac

AgentRX.cs

    var ts = myAgentList.ToObservable().Concat(      
                                                Observable.FromEventPattern
                                                    <NotifyCollectionChangedEventHandler, NotifyCollectionChangedEventArgs>
                                                    (
                                                            handler => myAgentList.CollectionChanged += handler,
                                                            handler => myAgentList.CollectionChanged -= handler
                                                    )
                                                .Where(e => e.EventArgs.Action == NotifyCollectionChangedAction.Add)
                                                .SelectMany(c => c.EventArgs.NewItems.Cast<MyAgent>()))                          
                                    .Select(agent => Observable.FromEventPattern<MyAgent.TickCallBack, int>(handler => agent.OnTick += handler,
                                                                                                         handler => agent.OnTick -= handler))
                                    .Merge();


       using (ts/*ObserveOn(new SynchronizationContextScheduler(SynchronizationContext.Current))*/
                .Subscribe(ev => Console.WriteLine("{0}:{1} Thread: {2}", ev.Sender, 
                                                                          ev.EventArgs, 
                                                                          Thread.CurrentThread.ManagedThreadId),
                           Console.WriteLine,
                           () => Console.WriteLine("OnCompleted")))
       {
            // Něco děláme, třeba přidáme agenty do kolekce …

   Console.ReadLine(); 
}