rxpy退会する方法

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

これは私のコードです。
私は購読する方法しか見つけませんが、ドライブからsまたはssを削除したい場合は。
私は何ができますか？
問題は、sとssの登録を解除する方法です。

Answer 1

drive.subscribe(s)は、使い捨てを返します。 dispose()を呼び出すと、あなたのオブザーバーは退会しています。

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