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