rxpy comment se désabonner

Question

from rx import Observable, Observer 
from rx.subjects import Subject 
drive = Observable.from_list(list(range(33))).publish() 

s = Subject() 
xs = s.buffer_with_count(6).do_action(print) 
xs.subscribe(print) 

ss = Subject() 
xss = ss.buffer_with_count(6).do_action(print) 
xss.subscribe() 

drive.subscribe(s) 
drive.subscribe(ss) 

drive.connect() 

Ceci est mon code.
Je trouve seulement le moyen de m'abonner, mais si je veux supprimer s ou ss du lecteur.
que puis-je faire.
La question est comment se désabonner s et ss.

Answer 1

drive.subscribe(s) renvoie Jetable. Appeler dispose() sur ce désinscrivant votre observateur.

d1=drive.subscribe(s) 
... 
d1.dispose()