python - 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) 正在返回一个 Disposable。调用 dispose() 取消订阅您的观察者。

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