0
A
回答
0
我砍死解决这个问题是这样的:
<T> Observable<T> discardOnceDelivered(BehaviorSubject<T> subject) {
return subject.filter(t -> t!=null).doOnNext(inputFields -> subject.onNext(null));
}
(处于RX 1.x中)唯一的限制是null
值不接受为有效发射值,而是用于编码丢弃的作用最后一个值。
相关问题
- 1. 刷新后保持可丢弃的最后一个位置
- 2. 放弃最后一个ArrayList
- 3. 比较列表后丢弃一个
- 4. RxJS函数从一个observable发出最后一个值然后发出true
- 5. VB.net从ipaddress(小数点后第三位)丢弃最后一个八位数
- 6. Qt丢弃事件后
- 7. TPL Dataflow Broadcastblock丢弃最后一条消息
- 8. 订购jQuery Droppable元素通过最后丢弃物品第一
- 9. 仅列出触发最后一个
- 10. 仅输出最后一个值
- 11. 光标只输出最后一个值
- 12. 退出for循环后ArrayList值设置为最后一个值
- 13. 最后一包丢失gnuradio
- 14. 放弃控件的SynchronizationContext发布队列中的最后一个。
- 15. 丢弃三个物体后触发图像更改
- 16. 连续最后一个按钮丢失
- 17. 如果某个功能在最后一刻被丢弃,您会做什么?
- 18. 如何只丢弃CKEditor撤消堆栈的最后一个元素?
- 19. jquery可排序 - 只允许在目标li中丢弃最后一个项目
- 20. DAX - 最后一个值
- 21. UIPickerView:最后一个值后面跟着第一个值
- 22. apache-commons-config PropertiesConfiguration:最后一个属性丢失后的注释
- 23. 明显丢弃group_后的列
- 24. ImageView在丢弃后不可见
- 25. jquery恢复丢弃后的图像
- 26. 如果GraphicsPath在使用后丢弃
- 27. 放弃最后3个字符
- 28. 丢弃git pull后,本地分支认为它是最新的
- 29. 搜索使用grep丢弃连字符在最后
- 30. 如何创建一次发出项目,然后从BehaviorSubject onComplete的Observable?
那么你为什么使用BehaviorSubject改为使用PublishSubject。 –
因为我希望价值坚持下去,直到有订户。 –
对于多个同时订阅用户来说,你希望所有用户在到达时都能获得相同的价值吗?单个用户可以消费多少价值,还是在获得某个项目后立即取消订阅? –