问题标签 [rx-py]

我正在模拟一些需要很长时间的输入的计算。每当完成计算（即on_next发出）时，我希望将结果反应性地附加到结果数据帧并在on_completed发出时打印最终的 DF。但是，DF 是空的，为什么没有值累积？

这适用于 Python 3.9.9 和 rxpy 3.2.0。

我想在另一个流中找到匹配项并将其与当前项目结合起来。

我希望打印这些：

但是我有：

有人可以给我一个想法，我做错了什么？

提前谢谢了

我过去曾使用过 RxJs 和 RxJava，我采用的常见做法是不在我的类的公共接口上公开主题，以不允许代码的其他部分发布新值。例如，在 rxjs 中，我会这样做：

例如，在 rxjava 中，我会这样做：

然而，最近，我一直在使用 RxPy，但在 RxPy 中找不到对应的asObservableor hide。有人可以帮忙吗？

我目前正在尝试将一个可调用对象包装到一个 rxpy observable 中，以通知其观察者必须处理一个新值，但我看不出这是如何轻松完成的，从观点来看，这对我来说似乎很奇怪相对经验丰富的 C++/Qt 开发人员。

我设法让像下面这样的样本工作，使用yield关键字，这在大多数情况下并不方便：

但是，如果您采用以下示例：

我只得到!! 1输出，2并且 3从未4被处理过，我并没有真正看到如何让我的观察者处理它们，但此外，我看不到如何在MyObservable中实现一个将值附加到我的列表的方法，并且触发观察者的处理。

我查看了 的 API Observable，认为也许可以从 启动某些东西source，但似乎并非如此。

通过尝试应用与 Qt 中相同的逻辑，我是否在rx/的哲学中遗漏了一些明显的东西，或者是否有一些简单的方法可以做到这一点，或者我的问题的解决方案是否需要实现适合我需要的专业化?rxpyObservable

无论如何，提前感谢您的任何回答！

编辑：我找到了一种不能完全满足我的方法，使用Subject类，它既是一个Observable又是一个Observer，所以我们可以使用它的on_next方法来通知外部订阅者一个新数据在这里：

此示例显示了我的期望：

但是，这绝对是rxpy我们期望我们做这种事情的方式，还是有比包装Subject对象更优雅的方式来做到这一点？