rx-py

0열

1답변

저는 주가 분석을위한 도구를 만들려고합니다. 다른 주식에 대한 가격 데이터 스트림이 있는데, 새롭고 별개의 완전한 가격 집합을받을 때마다 이벤트를 내 보내고 싶습니다. 내 계획 : 다른 주식에 대한 스트림을 다른 하위 스트림으로 그룹화하고 최신 값을 재결합합니다. a_source = price_source.filter(lambda x: x['stock']

0열

1답변

RxPY - stop_and_wait을 사용하는 방법?

는 파이썬에서 다음과 같은 자바 스크립트 코드 예제를 번역하려고 : import Rx from "rx" let source = Rx.Observable.interval(1000) .timestamp() .controlled(); source.stopAndWait().subscribe( (result) => console.lo

4열

1답변

, Observer.create에 다른 매개 변수를 전달하려면 어떻게해야합니까?

설명을 위해 RxPY 사용. 함수에서 관측 가능 함수를 만들고 싶지만이 함수는 매개 변수를 가져야합니다. 이 특정 예제는 임의의 간격으로, 내가 보내고 자하는 미리 정의 된 많은 시세 중 하나를 반환해야합니다. 지금까지의 해결 방법은 클로저를 사용하는 것입니다. from __future__ import print_function from rx impor

0열

1답변

RxPY (또는 RxJS) combine_latest와 group_by 관측 가능을 함께 사용하는 방법

ReactiveX에서 다음과 같이 각각 다른 주파수로 방사 될 수도 있고 그렇지 않을 수도있는 관측 가능한 수의 각각에서 최신 값을 취할 수 있습니다 (RxPY 사용).) : 나는 같은 일을 얼마나 관찰 가능한이를 사용하여 만든 상기 할 때 그러나 from __future__ import print_function from rx import Observ

1열

1답변

RxPy - 실시간 트위터 스트림을 수신 가능 상태로 변환합니까?

나는이 great tutorial을 따라 tweepy를 사용하여 파이썬에서 라이브 트위터 스트림을 활용했습니다. RxJava, RxPy, RxScala 또는 ReactiveX가 언급 된 실시간 트윗을 인쇄합니다. from tweepy.streaming import StreamListener from tweepy import OAuthHandler fro

1열

1답변

rxpy를 통해 observable에서 값을 반환

rx.Observable 객체를 함수의 '일반'객체로 변환하는 우아한 방법은 무엇입니까? 는 예 : class Foo: def __init__(self): self.buffer = None def call_kernel(self): rx.Observable.just('value').subscribe(lambda v:

0열

1답변

무효/단위 여기 아주 분명 뭔가를 누락 될 수 있습니다처럼

내 기분이 인수없이 on_next 함수를 호출하기위한 유형, 어쨌든 ... RxPY를 사용하여 C#을 RX System.Reactive.Unit 유형의 동등한이 인수없이 on_next 함수를 호출 한 경우? from rx import Observable source = Observable.return_value(???) source.subscribe(

0열

1답변

개체의 속성이 RxPy로 변경 될 때 함수를 트리거

RxPy에서 here을 언급 한 .NET 프레임 워크에서 INotifyPropertyChanged과 비슷한 것이 있습니까? 개체에 대한 관찰자를 추가하려고합니다. 개체의 속성이 변경되면 함수가 호출됩니다. 이 같은

0열

1답변

rxpy는 항목을 관찰 할 수있게 넣습니다.

이 질문은 rxpy에 관한 것입니다. 소스에서 관찰 할 수있는 메시지를 처리하는 반응적인 시스템을 구축하려고합니다. 그 외에도, 나는 그것을 사육사를 기반으로 한 리더 선거 시스템과 통합하려고 노력하고있다. 이 조합을 사용하면 프로세스 팜의 한 리더 만 메시지 스트림을 처리 할 수 있습니다. 아래는 내가 작성하려고하는 코드의 요지입니다. # event_

0열

1답변

RxPy에서 pyqtgraph 플롯을 관찰 가능합니다.

다음 스크립트에서 플롯 창이 생성되고 values은 plot.update으로 올바르게 전달됩니다. 그러나 플롯은 업데이트되지 않습니다. 내가 도대체 뭘 잘못하고있는 겁니까? import sys import time import numpy from numpy import pi import rx from rx.concurrency import