Мне очень трудно принять Reactive.Я считаю, что моя проблема в том, что примеры слишком упрощены, поэтому я не уверен, как структурировать реальное решение.Я надеюсь, что кто-то поможет мне преодолеть горб, помогая решить реальную проблему.Я хотел бы сделать это в RxPY v3.
Вариант использования таков.У вас есть бесконечный поток котировок акций для нескольких акций с символом, заявкой и запросом.У вас также есть количество позиции (сколько акций у вас есть), которое начинается с нуля.Котировки и количество на акцию - это бесконечные наблюдаемые значения.
У вас также есть три триггерные цены: цена входа, целевая цена и стоп-цена.Если ваша позиция равна нулю, тогда цена входа активна.Если цена акции повышается до цены входа, вы принимаете решение о покупке акции.Это приведет к тому, что ваша наблюдаемая позиция изменится на нечто большее, чем ноль.
Как только ваша позиция станет больше нуля, целевая цена и цена стопа станут активными.Если цена поднимется до целевой цены, вы предпримете действие по продаже акций с целью получения прибыли.Если цена упадет до стоп-цены, вы предпримете попытку продать акцию с убытком.В любом случае, ваша позиция снова станет нулевой, поэтому цена входа снова станет активной.
Является ли это хорошим вариантом использования RxPY?Если да, может ли кто-нибудь показать мне хотя бы псевдокод, если не реальный код, чтобы реализовать это?Я не уверен, как подойти к этому.Лучше всего это сделать в одном большом выражении или это как-то взаимодействие нескольких выражений?Всегда ли действие остается в бесконечной наблюдаемой цепочке, или эти вещи живут и умирают, живут и умирают при изменении состояния?
Любой вклад очень ценится.