RX Event Aggregator

gistfile1.cs

public class EventPublisher : IEventPublisher
{
    private readonly ConcurrentDictionary<Type, object> subjects
        = new ConcurrentDictionary<Type, object>();
 
    public IObservable<TEvent> GetEvent<TEvent>()
    {
        var subject = 
            (ISubject<TEvent>) subjects.GetOrAdd(typeof (TEvent), 
                        t => new Subject<TEvent>());
        return subject.AsObservable();
    }
 
    public void Publish<TEvent>(TEvent sampleEvent)
    {
        object subject;
        if (subjects.TryGetValue(typeof(TEvent), out subject))
        {
            ((ISubject<TEvent>)subject)
                .OnNext(sampleEvent);
        }
    }
}