RxPY - stop_and_wait을 사용하는 방법?

Question

는 파이썬에서 다음과 같은 자바 스크립트 코드 예제를 번역하려고 :

import Rx from "rx" 

let source = Rx.Observable.interval(1000) 
    .timestamp() 
    .controlled(); 

source.stopAndWait().subscribe(
    (result) => console.log("onNext: ", result), 
    (error) => console.log("onError: ", error), 
() => console.log("Done!") 
); 

코드 조각은 RxJS Release Notes에서 찍은. 내 파이썬 해석은 다음과 같습니다 : 불행하게도

from __future__ import print_function 
from rx import Observable 


source = Observable.interval(1000).timestamp().controlled() 
source.stop_and_wait().subscribe(
    on_next=lambda x: print("on_next %s" % x), 
    on_error=lambda e: print("on_error %s" % e) 
) 

, 자바 스크립트 버전은 파이썬 버전이 실패 잘 작동하는 동안 인해 'StopAndWaitObservable'개체가 어떤 속성 '가입'이 없다는 사실을.

Answer 1

rx 라이브러리 개발 라인에 문제의 픽스가 병합되었습니다. 수정 사항으로 파이썬 버전은 자바 스크립트처럼 작동합니다.