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