有谁知道如何使用 RxPy 缓冲具有可变计数的可观察流,其中计数基于缓冲数据的值?
例如,给定序列:
(d,1)-(d,2)-(d,2)-(d,3)-(d,3)-(d,3)-(d,2)-(d,2)-(d,3)-(d,3)-(d,3)
,
其中d
表示一些数据,缓冲区必须根据整数值顺序组合发射的项目,因此我们将得到 5 个缓冲发射,如下所示:
((d,1))-((d,2),(d,2))-((d,3),(d,3),(d,3))-((d,2),(d,2))-((d,3),(d,3),(d,3))