使用反应式扩展的事件聚合器的问题

连接我的 MEF 应用程序,我正在使用事件聚合器 found here . 它非常适合将数据分发到实际需要它的模块中。

我越来越喜欢使用反应式扩展,我一直在尝试以下操作:

eventSubscription = MainApp.Events.GetEvent<UDPMessageIn>()
                                  .BufferWithTime(TimeSpan.FromSeconds(1))
                                  .Subscribe(x => 
                                       { 
                                           // do something here...
                                       });

但是,事件聚合器似乎挂起在以下位置的发布方法中:

((ISubject<TEvent>)subject).OnNext(sampleEvent);

我猜关于系统、反应式或聚合器的设计有一些我不完全理解的东西。有人有什么想法吗?