python - 如何在 RxPY v3 中实现这个用例

Question

我发现 Reactive 很难采用。我相信我的问题是示例过于简单，因此我不确定如何构建现实世界的解决方案。我希望有人能通过帮助我解决现实世界的问题来帮助我克服困难。我想在 RxPY v3 中做到这一点。

用例是这样的。您可以通过代码、买入和卖出的方式为多只股票提供无限的股票报价流。您还有一个从零开始的头寸数量（您拥有多少股票）。每只股票的报价和数量是无限可观察的。

您还有三个触发价格：入场价、目标价和止损价。如果您的头寸为零，则入场价格有效。如果股票价格上涨到入场价，那么你就采取了买入股票的行动。这将导致您的可观察位置更改为大于零的值。

一旦您的仓位大于零，目标价和止损价就会生效。如果价格上涨至目标价格，您将采取卖出股票获利的行动。如果价格跌至止损价，您将采取亏损卖出股票的行动。无论哪种方式，您的头寸都会再次为零，因此入场价格将再次变得活跃。

这是 RxPY 的一个很好的用例吗？如果是这样，请至少给我看伪代码，如果不是真正的代码，来实现这个？我不知道如何解决这个问题。最好是在一个大表达式中完成，还是在某种程度上是多个表达式的交互？动作是否总是停留在一个永无止境的可观察链中，或者这些东西会随着状态的变化而生死存亡？

非常感谢任何输入。

标签： pythonreactive-programmingsystem.reactiverx-py

Answer 1

在http://pythondev.slack.com的#rxpy 频道中一些非常优秀的人的帮助下（特别向 Yev 大喊，我的 RxPY 夏尔巴人），我能够完成这项工作。 https://github.com/gargleblaster/rxpy_laboratory