安静的时期后，将RX序列计入批次

Question

我需要我的系统来发送一封电子邮件，总结一段时间后发生的事情。我该如何使用RX？

Answer 1

尝试以下：

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