rx-py

    0

    1答えて

    私はPythonで次のJavaScriptコードの例を翻訳してみました: import Rx from "rx" let source = Rx.Observable.interval(1000) .timestamp() .controlled(); source.stopAndWait().subscribe( (result) => console.log

    0

    2答えて

    質問:私は一連の操作の出力を外部変数のオブザーバブルに保存する方法を見つけることができません。そのような 例えば何か: mylist = [] Observable.from_([1, 2, 3]).to_list().store(mylist) わからない、これは非常に「反応」ですが、些細なことする必要があります。 mylist = [] def store(value):

    4

    1答えて

    説明のためにRxPYを使用しています。 私は関数からオブザーバブルを作成したいが、その関数はパラメータを取らなければならない。この特定の例は、ランダムな間隔で、私がそれに送るたくさんのあらかじめ定義されたティッカーの1つを返す必要があります。これまでの私の解決策は、クロージャを使用することです: from __future__ import print_function from rx imp

    0

    1答えて

    ReactiveXでは、次のように、それぞれが異なる周波数で放射する可能性のある観測値から最新の観測値を取り出すことができます(RxPY ):観測のいずれかが観測を使用して作成されたと述べた値を、発するたび from __future__ import print_function from rx import Observable import time import IPython

    1

    1答えて

    これに続いて、great tutorialはtweepyを使ってPythonでライブのTwitterストリームを活用しています。これにより、RxJava、RxPy、RxScala、またはReactiveXというライブタイムでツイートが印刷されます。 from tweepy.streaming import StreamListener from tweepy import OAuthHandle

    0

    2答えて

    PythonでReactiveXを使用すると、Observablesのストリームをどのように要約できますか? {"user": "..."、 "date":...}の辞書があります。私は、各ユーザの最新の日付で辞書を累積し、ストリームの終わりがヒットしたときに累積された観測値を出力する関数を作成したい(maxのようだが、ユーザフィールドを見る必要があり、値)。 例 - 入力ストリーム: { "us

    1

    1答えて

    rx.Observableオブジェクトを関数の '通常の'オブジェクトに変換するうまい方法は何ですか? 例: def foo(): return rx.Observable.just('value').subscribe(<some magic here>) >>> print(foo()) # expected: # value # however get: # <rx.

    0

    1答えて

    この質問は​​に関するものです。 ソースオブザーバブルからのメッセージを処理するリアクティブシステムを構築しようとしています。それに加えて、私はそれを飼い犬飼い主に基づくリーダー選挙システムと統合しようとしています。 この組み合わせでは、プロセスファーム内のリーダーだけがメッセージストリームを処理できます。以下は私が構築しようとしているコードの要点です。 # event_source is an

    0

    1答えて

    プロットウィンドウが作成され、valuesが正しくplot.updateに渡されます。しかし、プロットは更新されていません。私は間違って何をしていますか? import sys import time import numpy from numpy import pi import rx from rx.concurrency import QtScheduler import