如何在rxpyv3中实现这个用例

Question

我发现很难接受。我认为我的问题是这些例子过于简单，所以我不确定如何构建一个真实世界的解决方案。我希望有人能帮助我克服困难，帮助我解决现实世界中的问题。我想在rxpyv3中执行此操作。你知道吗

用例是这样的。你有一个无限流的股票报价为多个股票来与符号，出价，并要求。你也有一个仓位数量（你拥有多少股），从零开始。每只股票的报价和数量是无限可观察的。你知道吗

你还有三个触发价格：一个进入价格，一个目标价格，和一个停止价格。如果你的仓位为零，那么进场价是有效的。如果股票价格上升到入门价，那么你就采取购买股票的行动。这将导致你的可观察位置改变为大于零的值。你知道吗

一旦你的仓位大于零，目标价和止损价就会激活。如果价格上涨到目标价，你将采取出售股票获利的行动。如果价格跌至止损价，你将采取亏本卖出股票的行动。不管是哪种方式，你的仓位再次为零，因此进场价将再次活跃。你知道吗

这是RxPY的一个好用例吗？如果是这样的话，请至少有人给我看看伪代码，如果不是真的代码，来实现这个？我不知道该怎么做。它最好是在一个大的表达式中完成，还是在某种程度上是多个表达式的交互作用？行为是否总是停留在一个永无止境的可观察的链条中，或者这些事物是否随着状态的变化而生与死？你知道吗

非常感谢您的任何意见。你知道吗

Answer 1

在http://pythondev.slack.com的#rxpy频道的一些非常好的人的帮助下（特别是向耶夫喊话，我的rxpy夏尔巴人），我能够使这个工作。https://github.com/gargleblaster/rxpy_laboratory