反应式框架(RX)和异步处理事件

所以我只是在玩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在不同的线程上调用Subscribe?