类之间的rxpy BehaviorSubject

问题描述

我正在尝试在类之间实现BehaviorSubject以更新进度。我使用rx python库

class ProgressBehavior:

def __init__(self):
    self.progress = BehaviorSubject(0)

这是我用来创建BehaviorSubject的类

然后在我需要订阅的课程中

self.progress_behavior = ProgressBehavior().progress
self.progress_behavior.subscribe(on_next=lambda value: self.update_progress(value))

仅当尝试更新其他类中的BehaviorSubject时，此功能才第一次使用

class Downloader:
def __init__(self):
    self.progress = ProgressBehavior().progress

并向所有订阅者发送通知

self.progress.on_next(25)

我所缺少的？？？ 谢谢

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）