在一段安靜時間後，將RX序列時間轉換爲批次？

Question

我需要我的系統發送一封電子郵件，總結一段時間不活動後發生的事情。我如何用RX做到這一點？

Answer 1

試試這個：

IObservable<IList<T>> query = 
    source.Publish(hot => hot.Buffer(() => hot.Throttle(TimeSpan.FromSeconds(1.0))));