RxPY - Comment utiliser stop_and_wait?

Question

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().subscribe(
    (result) => console.log("onNext: ", result), 
    (error) => console.log("onError: ", error), 
() => console.log("Done!") 
); 

L'extrait a été prise du RxJS Release Notes. Mon interprétation Python se présente comme suit:

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) 
) 

Malheureusement, tandis que la version JavaScript fonctionne très bien la version Python échoue en raison du fait que l'objet « StopAndWaitObservable » n'a pas d'attribut « abonnement ».

Answer 1

Un correctif pour le problème a été fusionné dans la ligne de développement de la bibliothèque rx. Avec la version corrective Python fonctionne exactement comme JavaScript.