rx-py

0La chaleur

1Répondre

Comment recombiner correctement des observables groupés?

J'essaie de créer un outil pour analyser les cours boursiers. J'ai un flux de données de prix pour différents stocks, et je veux avoir un observable pour émettre des événements chaque fois qu'il reçoi

python-3.x system.reactive reactive-programming reactivex rx-py 2017-05-06

---

0La chaleur

1Répondre

RxPY - Comment utiliser stop_and_wait?

J'ai essayé de traduire l'exemple de code JavaScript suivant en Python: import Rx from "rx" let source = Rx.Observable.interval(1000) .timestamp() .controlled(); source.stopAndWait().sub

python rx-py 2017-01-28

---

1La chaleur

1Répondre

RxPy - Pourquoi les émissions sont-elles entrelacées avec les opérateurs de fusion?

Alors j'apprends RxPy après avoir fait RxJava et RxKotlin pendant deux ans. Une chose que je remarque est que certains opérateurs provoquent un entrelacement fou qui ne se produit pas dans RxJava. Par

python rx-java reactive-programming rx-py 2016-10-24

---

0La chaleur

1Répondre

Valeur de passage RxPy à l'observateur

Existe-t-il un moyen de transmettre la valeur à l'observateur en fonction de l'entrée de l'utilisateur (ce qui signifie que la valeur transmise n'est pas fixe tout le temps)? from rx import Observable

python rx-py 2017-07-14

---

0La chaleur

2Répondre

résumant Observables dans reactivex python

Avec ReactiveX en Python, comment puis-je résumer un flux d'Observables? J'ai un flux de dictionnaires qui sont {"user": "...", "date": ...}. Je veux faire une fonction que je peux appliquer qui accum

python reactivex rx-py 2017-02-17

---

1La chaleur

1Répondre

renvoyer une valeur à partir d'observable via rxpy

Quelle est la manière élégante de convertir un objet rx.Observable en un objet 'normal' dans une fonction? par exemple: def foo(): return rx.Observable.just('value').subscribe(<some magic here>)

python reactivex rx-py 2017-09-05

---

14La chaleur

5Répondre

Comment faire pour temporiser un programme en cours d'exécution en utilisant rxpython?

Dites que j'ai une fonction python longue qui ressemble à ceci? import random import time from rx import Observable def intns(x): y = random.randint(5,10) print(y) print('begin')

python system.reactive reactive-programming rx-py 2017-07-20

---

0La chaleur

1Répondre

Déclencher une fonction quand une propriété d'un objet change avec RxPy

Dans RxPy, y a-t-il quelque chose de similaire à INotifyPropertyChanged dans le framework .NET mentionné here? J'essaie d'ajouter un observateur à un objet, de sorte que toute propriété de l'objet cha

python-3.x reactive-programming rx-py 2016-09-28

---

0La chaleur

1Répondre

rxpy injecter des éléments dans observable

Cette question concerne rxpy. J'essaye de construire un système réactif qui manipule des messages d'une source observable. En plus de cela, j'essaie de l'intégrer avec un système d'élection de chef ba

operators reactivex rx-py 2017-04-18

---

0La chaleur

1Répondre

Mise à jour du tracé pyqtgraph à partir de RxPy observable

Dans le script suivant, une fenêtre de tracé est créée et values est correctement transmise à plot.update. Cependant, l'intrigue n'est pas mise à jour. Qu'est-ce que je fais mal? import sys import ti

python pyqtgraph rx-py 2016-12-02

---