我有一个流生成器,我想从流中访问先前发出的值。如果熟悉 distinct,他们必须知道 distinct 基本上检查先前值和当前值是否相同。我想访问以前的值。创建我自己的自定义条件。
我正在使用来自 RxDart 的重播主题,最大容量:2 replay-subject 的所有实例都被新数据替换。因此,我无权访问以前的数据,它只是被覆盖了。我被困在如何将数据添加到重播主题方面需要帮助。如果不使用 sink.add() 方法
我有一个流生成器,我想从流中访问先前发出的值。如果熟悉 distinct,他们必须知道 distinct 基本上检查先前值和当前值是否相同。我想访问以前的值。创建我自己的自定义条件。
我正在使用来自 RxDart 的重播主题,最大容量:2 replay-subject 的所有实例都被新数据替换。因此,我无权访问以前的数据,它只是被覆盖了。我被困在如何将数据添加到重播主题方面需要帮助。如果不使用 sink.add() 方法
根据提交的 Github 票证,此错误行为应由rxdart 0.20.0 版本修复。
另外,正如在这个线程中提到的,我相信这个问题可以通过#210来回答,并且现在应该可用。
使用参数时,此修复程序应正确处理
buffer
oncount
和window
on 。count
startBufferEvery
这是一个重大变化:
- startBufferEvery 现在应该可以正常工作
- 当父级
Stream
完成时,我们不再将余数添加buffer
为 finalevent
:即,如果将buffer
设置为按 3 个事件分组,并且父级Stream
输出1, 2, 3, 4
,那么唯一event
的 onbuffer(3)
将是[1, 2, 3]
。之前,我们也将[4]
作为剩余部分派发onDone
。