建议在长时间运行的过程中使用rx与众不同？

Question

我正在使用rx不同运算符在长时间运行的过程中基于某个键来过滤外部数据流。

这会导致内存泄漏吗？假设将收到许多不同的密钥。rx区分运算符如何跟踪先前收到的密钥？

我应该将groupbyuntil与持续时间选择器一起使用吗？

Answer 1

Observable.Distinct在HashSet内部使用。内存使用情况将与遇到的不同键的数量大致成比例。（AFAIK大约30 * n字节）

GroupByUntil做的事情确实与Distinct。
GroupByUntil（好）组，而Distinct过滤流的元素。

不确定预期用途，但是如果您只想过滤连续的相同元素，则需要Observable.DistinctUntilChanged的存储空间与键的数量无关。