为了连接我的MEF应用程序,我使用了在此处找到的事件聚合器。它非常适合将数据分发到实际需要它的模块中。
我越来越多地使用响应式扩展,并且一直在尝试执行以下操作:
eventSubscription = MainApp.Events.GetEvent<UDPMessageIn>()
.BufferWithTime(TimeSpan.FromSeconds(1))
.Subscribe(x =>
{
// do something here...
});
但是,事件聚合器似乎挂在 Publish 方法中:
((ISubject<TEvent>)subject).OnNext(sampleEvent);
我猜想 system.reactive 或聚合器的设计有一些我不完全理解的东西。有人有什么想法吗?