所以我只是在玩RX并学习它。我开始玩事件,想知道如何订阅事件,并异步处理结果。请允许我用代码解释:
引发事件的简单类:
public class EventRaisingClass
{
public event EventHandler<SomeEventArgs> EventOccured;
//some other code that raises event...
}
public class SomeEventArgs : EventArgs
{
public SomeEventArgs(int data)
{
this.SomeArg = data;
}
public int SomeArg { get; private set; }
}
然后我的主要:
public static void Main(string[] args)
{
var eventRaiser = new EventRaisingClass();
IObservable<IEvent<SomeEventArgs>> observable =
Observable.FromEvent<SomeEventArgs>(e => eventRaiser.EventOccured += e, e => eventRaiser.EventOccured -= e);
IObservable<IList<IEvent<SomeEventArgs>>> bufferedEvents = observable.BufferWithCount(100);
//how can I subscribte to bufferedEvents so that the subscription code gets called Async?
bufferedEvents.Subscribe(list => /*do something with list of event args*/); //this happens synchrounously...
}
正如您在我的评论中看到的,当您像这样调用 subscribe 时,所有订阅代码都会同步发生。每当有新的一批事件要处理时,是否有一种开箱即用的方法使用 RX 在不同的线程上调用订阅?