在安静期后将 RX 序列时移到批处理中？
Timeshift an RX sequence into a batch after a quiet period?
我需要我的系统发送一封电子邮件，总结一段时间不活动后发生的事情。我如何使用 RX 执行此操作？
试试这个：
IObservable<IList<T>> query =
source.Publish(hot => hot.Buffer(() => hot.Throttle(TimeSpan.FromSeconds(1.0))));
我需要我的系统发送一封电子邮件，总结一段时间不活动后发生的事情。我如何使用 RX 执行此操作？
试试这个：
IObservable<IList<T>> query =
source.Publish(hot => hot.Buffer(() => hot.Throttle(TimeSpan.FromSeconds(1.0))));